From 710d8dc12afc3befff667f2e8096ad187dc79443 Mon Sep 17 00:00:00 2001
From: Matthew Swift <matthew.swift@forgerock.com>
Date: Fri, 02 Dec 2011 10:06:04 +0000
Subject: [PATCH] Fix OPENDJ-374: Remove BlockingQueue parameter from Connection.search(SearchRequest, BlockingQueue)
---
opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/AbstractConnection.java | 10 +++-------
1 files changed, 3 insertions(+), 7 deletions(-)
diff --git a/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/AbstractConnection.java b/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/AbstractConnection.java
index 869c71d..e6e7726 100644
--- a/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/AbstractConnection.java
+++ b/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/AbstractConnection.java
@@ -36,8 +36,6 @@
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;
@@ -490,12 +488,11 @@
* {@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);
}
@@ -589,10 +586,9 @@
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);
}
--
Gitblit v1.10.0