From 45141fb11ef698b11c6fb3becca82ca10e11505a Mon Sep 17 00:00:00 2001
From: Gaetan Boismal <gaetan.boismal@forgerock.com>
Date: Mon, 15 Sep 2014 12:50:50 +0000
Subject: [PATCH] OPENDJ-1285 CR-4409 Migrate SDK from Futures to Promises
---
opendj-server3x-adapter/src/main/java/org/forgerock/opendj/adapter/server3x/Adapters.java | 21 +++++++--------------
1 files changed, 7 insertions(+), 14 deletions(-)
diff --git a/opendj-server3x-adapter/src/main/java/org/forgerock/opendj/adapter/server3x/Adapters.java b/opendj-server3x-adapter/src/main/java/org/forgerock/opendj/adapter/server3x/Adapters.java
index f6abb09..e5b62bb 100644
--- a/opendj-server3x-adapter/src/main/java/org/forgerock/opendj/adapter/server3x/Adapters.java
+++ b/opendj-server3x-adapter/src/main/java/org/forgerock/opendj/adapter/server3x/Adapters.java
@@ -38,10 +38,8 @@
import org.forgerock.opendj.ldap.DecodeException;
import org.forgerock.opendj.ldap.DecodeOptions;
import org.forgerock.opendj.ldap.ErrorResultException;
-import org.forgerock.opendj.ldap.FutureResult;
import org.forgerock.opendj.ldap.IntermediateResponseHandler;
import org.forgerock.opendj.ldap.ResultCode;
-import org.forgerock.opendj.ldap.ResultHandler;
import org.forgerock.opendj.ldap.SearchResultHandler;
import org.forgerock.opendj.ldap.controls.Control;
import org.forgerock.opendj.ldap.requests.AddRequest;
@@ -63,6 +61,7 @@
import org.forgerock.opendj.ldap.responses.GenericExtendedResult;
import org.forgerock.opendj.ldap.responses.Responses;
import org.forgerock.opendj.ldap.responses.Result;
+import org.forgerock.util.promise.Promise;
import org.opends.server.core.AddOperation;
import org.opends.server.core.BindOperation;
import org.opends.server.core.CompareOperation;
@@ -78,10 +77,9 @@
import org.opends.server.types.SearchResultEntry;
import org.opends.server.types.SearchResultReference;
-import com.forgerock.opendj.util.CompletedFutureResult;
-
import static org.forgerock.opendj.adapter.server3x.Converters.*;
import static org.forgerock.opendj.ldap.ByteString.*;
+import static org.forgerock.util.promise.Promises.*;
/**
* This class provides a connection factory and an adapter for the OpenDJ 2.x
@@ -141,8 +139,7 @@
* @return A new SDK connection factory.
*/
public static ConnectionFactory newConnectionFactory(final InternalClientConnection icc) {
- final Connection connection = newConnection(icc);
- ConnectionFactory factory = new ConnectionFactory() {
+ return new ConnectionFactory() {
@Override
public void close() {
@@ -150,20 +147,16 @@
}
@Override
- public FutureResult<Connection> getConnectionAsync(
- ResultHandler<? super Connection> handler) {
- if (handler != null) {
- handler.handleResult(connection);
- } // TODO change the path...
- return new CompletedFutureResult<Connection>(connection);
+ public Promise<Connection, ErrorResultException> getConnectionAsync() {
+ // TODO change the path...
+ return newSuccessfulPromise(newConnection(icc));
}
@Override
public Connection getConnection() throws ErrorResultException {
- return connection;
+ return newConnection(icc);
}
};
- return factory;
}
/**
--
Gitblit v1.10.0