public class AggregatePooledSearchExecutor extends AbstractAggregateSearchExecutor<PooledConnectionFactory>
AggregateSearchExecutor
. A cached thread pool is used by default.logger
Constructor and Description |
---|
AggregatePooledSearchExecutor()
Default constructor.
|
AggregatePooledSearchExecutor(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. |
Collection<Response<SearchResult>> |
search(PooledConnectionFactory[] 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 AggregatePooledSearchExecutor()
public AggregatePooledSearchExecutor(ExecutorService es)
es
- executor servicepublic Collection<Response<SearchResult>> search(PooledConnectionFactory[] factories, SearchFilter[] filters, String[] attrs, SearchEntryHandler... handlers) throws LdapException
AbstractAggregateSearchExecutor
search
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> 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 operationCopyright © 2003-2019 Virginia Tech. All Rights Reserved.