public class ParallelPooledSearchExecutor extends AbstractParallelSearchExecutor<PooledConnectionFactory>
ParallelSearchExecutor
. A cached thread pool is used
by default.logger
Constructor and Description |
---|
ParallelPooledSearchExecutor()
Default constructor.
|
ParallelPooledSearchExecutor(ExecutorService es)
Creates a new parallel 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 factory,
SearchFilter[] filters,
String[] attrs,
SearchEntryHandler... handlers)
Performs a search operation with the supplied connection factory.
|
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 ParallelPooledSearchExecutor()
public ParallelPooledSearchExecutor(ExecutorService es)
es
- executor servicepublic Collection<Response<SearchResult>> search(PooledConnectionFactory factory, SearchFilter[] filters, String[] attrs, SearchEntryHandler... handlers) throws LdapException
AbstractParallelSearchExecutor
search
in class AbstractParallelSearchExecutor<PooledConnectionFactory>
factory
- 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.