public class AggregatePooledSearchExecutor extends AbstractAggregateSearchExecutor<PooledConnectionFactory>
AggregateSearchExecutor. A cached thread pool is used by default.logger| Constructor and Description |
|---|
AggregatePooledSearchExecutor()
Default constructor.
|
AggregatePooledSearchExecutor(java.util.concurrent.ExecutorService es)
Creates a new aggregate pooled search executor.
|
| Modifier and Type | Method and Description |
|---|---|
protected static <Q extends Request,S> |
createCallable(Connection conn,
Operation<Q,S> operation,
Q request)
Returns a
Callable that executes the supplied request with the supplied operation in a try-finally block
that opens and closes the connection. |
java.util.Collection<Response<SearchResult>> |
search(PooledConnectionFactory[] factories,
SearchFilter[] filters,
java.lang.String[] attrs,
SearchEntryHandler... handlers)
Performs a search operation with the supplied connection factories.
|
search, search, search, searchcreateSearchOperation, finalize, getExecutorService, getSearchCache, getSearchExceptionHandler, getSearchResponseHandlers, setSearchCache, setSearchExceptionHandler, setSearchResponseHandlers, shutdown, shutdownNow, toStringequals, getBaseDn, getBinaryAttributes, getDerefAliases, getReturnAttributes, getSearchEntryHandlers, getSearchFilter, getSearchReferenceHandlers, getSearchScope, getSizeLimit, getSortBehavior, getTimeLimit, getTypesOnly, hashCode, newObjectScopeSearchRequest, newObjectScopeSearchRequest, newObjectScopeSearchRequest, newSearchRequest, setBaseDn, setBinaryAttributes, setDerefAliases, setReturnAttributes, setSearchEntryHandlers, setSearchFilter, setSearchReferenceHandlers, setSearchScope, setSizeLimit, setSortBehavior, setTimeLimit, setTypesOnlygetControls, getIntermediateResponseHandlers, getReferralHandler, setControls, setIntermediateResponseHandlers, setReferralHandlerpublic AggregatePooledSearchExecutor()
public AggregatePooledSearchExecutor(java.util.concurrent.ExecutorService es)
es - executor servicepublic java.util.Collection<Response<SearchResult>> search(PooledConnectionFactory[] factories, SearchFilter[] filters, java.lang.String[] attrs, SearchEntryHandler... handlers) throws LdapException
AbstractAggregateSearchExecutorsearch in class AbstractAggregateSearchExecutor<PooledConnectionFactory>factories - to get a connection fromfilters - to search withattrs - to returnhandlers - entry handlersLdapException - if the search failsprotected static <Q extends Request,S> java.util.concurrent.Callable<Response<S>> createCallable(Connection conn, Operation<Q,S> operation, Q request)
Callable that executes the supplied request with the supplied operation in a try-finally block
that opens and closes the connection.Q - type of ldap requestS - type of ldap responseconn - connection that the operation will execute onoperation - to executerequest - to pass to the operation