| | |
| | | import static org.forgerock.opendj.ldap.ErrorResultException.newErrorResult; |
| | | |
| | | import java.util.Collection; |
| | | import java.util.concurrent.BlockingQueue; |
| | | import java.util.concurrent.LinkedBlockingQueue; |
| | | import java.util.concurrent.TimeUnit; |
| | | import java.util.concurrent.TimeoutException; |
| | | |
| | |
| | | * {@inheritDoc} |
| | | */ |
| | | @Override |
| | | public ConnectionEntryReader search(final SearchRequest request, |
| | | final BlockingQueue<Response> entries) |
| | | public ConnectionEntryReader search(final SearchRequest request) |
| | | throws UnsupportedOperationException, IllegalStateException, |
| | | NullPointerException |
| | | { |
| | | return new ConnectionEntryReader(this, request, entries); |
| | | return new ConnectionEntryReader(this, request); |
| | | } |
| | | |
| | | |
| | |
| | | throws UnsupportedOperationException, IllegalStateException, |
| | | NullPointerException |
| | | { |
| | | final BlockingQueue<Response> entries = new LinkedBlockingQueue<Response>(); |
| | | final SearchRequest request = Requests.newSearchRequest(baseObject, scope, |
| | | filter, attributeDescriptions); |
| | | return search(request, entries); |
| | | return search(request); |
| | | } |
| | | |
| | | |