| Package | Description |
|---|---|
| org.ldaptive.concurrent |
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> |
QueueingSearchExecutor.AbstractHandler.queue
Blocking queue to put items on.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> |
QueueingSearchExecutor.search(ConnectionFactory factory)
Performs a search operation with the supplied connection factory.
|
java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> |
QueueingSearchExecutor.search(ConnectionFactory factory,
SearchFilter filter)
Performs a search operation with the supplied connection factory.
|
java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> |
QueueingSearchExecutor.search(ConnectionFactory factory,
SearchFilter filter,
java.lang.String... attrs)
Performs a search operation with the supplied connection factory.
|
java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> |
QueueingSearchExecutor.search(ConnectionFactory factory,
SearchFilter filter,
java.lang.String[] attrs,
SearchEntryHandler... handlers)
Performs a search operation with the supplied connection factory.
|
java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> |
QueueingSearchExecutor.search(ConnectionFactory factory,
java.lang.String filter)
Performs a search operation with the supplied connection factory.
|
java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> |
QueueingSearchExecutor.search(ConnectionFactory factory,
java.lang.String filter,
java.lang.String... attrs)
Performs a search operation with the supplied connection factory.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
QueueingSearchExecutor.AbstractHandler.insert(QueueingSearchExecutor.SearchItem item)
Places the supplied item on the blocking queue.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
QueueingSearchExecutor.configureSearchRequest(SearchRequest request,
java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> queue)
Sets the appropriate handlers on the supplied search request so that entries, references, and intermediate
responses are made available on the supplied queue.
|
protected java.util.concurrent.Callable<Response<SearchResult>> |
QueueingSearchExecutor.createCallable(Connection conn,
SearchOperation operation,
SearchRequest request,
java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> queue)
Returns a
Callable that executes the supplied request with the supplied operation in a try-finally block
that opens and closes the connection. |
| Constructor and Description |
|---|
AbstractHandler(java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> q)
Creates a new abstract handler.
|
IntermediateResponseHandler(java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> q)
Creates a new intermediate response handler.
|
SearchEntryHandler(java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> q)
Creates a new search entry handler.
|
SearchReferenceHandler(java.util.concurrent.BlockingQueue<QueueingSearchExecutor.SearchItem> q)
Creates a new search reference handler.
|