From 6439bba5cc09d6febc59bdc9e0d9bc25f1f1eb18 Mon Sep 17 00:00:00 2001
From: matthew_swift <matthew_swift@localhost>
Date: Wed, 01 Sep 2010 09:04:15 +0000
Subject: [PATCH] Various improvements:
---
sdk/src/org/opends/sdk/SynchronousConnection.java | 23 ++++++++++++++++-------
1 files changed, 16 insertions(+), 7 deletions(-)
diff --git a/sdk/src/org/opends/sdk/SynchronousConnection.java b/sdk/src/org/opends/sdk/SynchronousConnection.java
index 1d82232..b1bac79 100644
--- a/sdk/src/org/opends/sdk/SynchronousConnection.java
+++ b/sdk/src/org/opends/sdk/SynchronousConnection.java
@@ -22,22 +22,21 @@
* CDDL HEADER END
*
*
- * Copyright 2009 Sun Microsystems, Inc.
+ * Copyright 2009-2010 Sun Microsystems, Inc.
*/
package org.opends.sdk;
+import org.opends.sdk.ldif.ConnectionEntryReader;
import org.opends.sdk.requests.*;
-import org.opends.sdk.responses.BindResult;
-import org.opends.sdk.responses.CompareResult;
-import org.opends.sdk.responses.ExtendedResult;
-import org.opends.sdk.responses.Result;
+import org.opends.sdk.responses.*;
import org.opends.sdk.schema.Schema;
import com.sun.opends.sdk.util.Validator;
+import java.util.concurrent.BlockingQueue;
/**
@@ -350,8 +349,7 @@
InterruptedException, UnsupportedOperationException,
IllegalStateException, NullPointerException
{
- final FutureResult<Result> future = connection.search(request, null,
- handler);
+ final FutureResult<Result> future = connection.search(request, handler);
try
{
return future.get();
@@ -363,4 +361,15 @@
}
}
+ /**
+ * {@inheritDoc}
+ */
+ public ConnectionEntryReader search(final SearchRequest request,
+ BlockingQueue<Response> entries)
+ throws UnsupportedOperationException, IllegalStateException,
+ NullPointerException
+ {
+ return new ConnectionEntryReader(getAsynchronousConnection(),
+ request, entries);
+ }
}
--
Gitblit v1.10.0