public class AggregateSearchExecutor extends AbstractAggregateSearchExecutor<ConnectionFactory>
AggregatePooledSearchExecutor
. A cached thread pool is used by default.logger
Constructor and Description |
---|
AggregateSearchExecutor()
Default constructor.
|
AggregateSearchExecutor(ExecutorService es)
Creates a new aggregate search executor.
|
Modifier and Type | Method and Description |
---|---|
protected static <Q extends Request,S> |
createCallable(Connection conn,
OperationWorker<Q,S> worker,
Q[] requests)
Returns a
Callable that executes the supplied request with the supplied worker in a try-finally block that
opens and closes the connection. |
Collection<Response<SearchResult>> |
search(ConnectionFactory[] factories,
SearchFilter[] filters,
String[] attrs,
SearchEntryHandler... handlers)
Performs a search operation with the supplied connection factories.
|
search, search, search, search
createSearchOperation, finalize, getExecutorService, getSearchCache, getSearchExceptionHandler, getSearchResponseHandlers, setSearchCache, setSearchExceptionHandler, setSearchResponseHandlers, shutdown, shutdownNow, toString
equals, 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, setTypesOnly
getControls, getIntermediateResponseHandlers, getReferralHandler, setControls, setIntermediateResponseHandlers, setReferralHandler
public AggregateSearchExecutor()
public AggregateSearchExecutor(ExecutorService es)
es
- executor servicepublic Collection<Response<SearchResult>> search(ConnectionFactory[] factories, SearchFilter[] filters, String[] attrs, SearchEntryHandler... handlers) throws LdapException
AbstractAggregateSearchExecutor
search
in class AbstractAggregateSearchExecutor<ConnectionFactory>
factories
- to get a connection fromfilters
- to search withattrs
- to returnhandlers
- entry handlersLdapException
- if the search failsprotected static <Q extends Request,S> Callable<Collection<Response<S>>> createCallable(Connection conn, OperationWorker<Q,S> worker, Q[] requests)
Callable
that executes the supplied request with the supplied worker in a try-finally block that
opens and closes the connection.Q
- type of ldap requestS
- type of ldap responseconn
- connection that the worker will execute onworker
- to executerequests
- to pass to the workerCopyright © 2003-2019 Virginia Tech. All Rights Reserved.