OPENDJ-832 Leverage the work queue for processing requests received on the ...

Jean-Noel Rouvignac

27.12.2013 cd55d08a6829f05a8a42fb0ca625615aa5be81f2

 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() {