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/AbstractLoadBalancingAlgorithm.java | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/AbstractLoadBalancingAlgorithm.java b/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/AbstractLoadBalancingAlgorithm.java
index 3951e19..aead5f3 100644
--- a/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/AbstractLoadBalancingAlgorithm.java
+++ b/opendj3/opendj-ldap-sdk/src/main/java/org/forgerock/opendj/ldap/AbstractLoadBalancingAlgorithm.java
@@ -27,7 +27,7 @@
package org.forgerock.opendj.ldap;
-import static org.forgerock.opendj.ldap.ErrorResultException.newErrorResult;
+import static org.forgerock.opendj.ldap.ErrorResultException.*;
import java.util.ArrayList;
import java.util.Collection;
@@ -70,6 +70,7 @@
/**
* {@inheritDoc}
*/
+ @Override
public Connection getConnection() throws ErrorResultException {
final Connection connection;
try {
@@ -92,8 +93,8 @@
@Override
public FutureResult<Connection> getConnectionAsync(
final ResultHandler<? super Connection> resultHandler) {
- final AsynchronousFutureResult<Connection> future =
- new AsynchronousFutureResult<Connection>(resultHandler);
+ final AsynchronousFutureResult<Connection, ResultHandler<? super Connection>> future =
+ new AsynchronousFutureResult<Connection, ResultHandler<? super Connection>>(resultHandler);
final ResultHandler<Connection> failoverHandler = new ResultHandler<Connection>() {
@Override
--
Gitblit v1.10.0