From cd55d08a6829f05a8a42fb0ca625615aa5be81f2 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 27 Mar 2013 12:12:50 +0000
Subject: [PATCH] OPENDJ-832 Leverage the work queue for processing requests received on the HTTP connection handler
---
opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/FixedConnectionPool.java | 13 +++++++------
1 files changed, 7 insertions(+), 6 deletions(-)
diff --git a/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/FixedConnectionPool.java b/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/FixedConnectionPool.java
index df6795b..bc6cc11 100644
--- a/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/FixedConnectionPool.java
+++ b/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/FixedConnectionPool.java
@@ -27,9 +27,10 @@
package org.forgerock.opendj.ldap;
-import static com.forgerock.opendj.util.StaticUtils.DEBUG_LOG;
-import static org.forgerock.opendj.ldap.CoreMessages.ERR_CONNECTION_POOL_CLOSING;
-import static org.forgerock.opendj.ldap.ErrorResultException.newErrorResult;
+import static com.forgerock.opendj.util.StaticUtils.*;
+
+import static org.forgerock.opendj.ldap.CoreMessages.*;
+import static org.forgerock.opendj.ldap.ErrorResultException.*;
import java.util.Collection;
import java.util.LinkedList;
@@ -536,7 +537,7 @@
}
QueueElement(final ResultHandler<? super Connection> handler) {
- this.value = new AsynchronousFutureResult<Connection>(handler);
+ this.value = new AsynchronousFutureResult<Connection, ResultHandler<? super Connection>>(handler);
}
@Override
@@ -553,8 +554,8 @@
}
@SuppressWarnings("unchecked")
- AsynchronousFutureResult<Connection> getWaitingFuture() {
- return (AsynchronousFutureResult<Connection>) value;
+ AsynchronousFutureResult<Connection, ResultHandler<? super Connection>> getWaitingFuture() {
+ return (AsynchronousFutureResult<Connection, ResultHandler<? super Connection>>) value;
}
boolean isWaitingFuture() {
--
Gitblit v1.10.0