From 5511a94238385a30b5b516ee360b234ff56d7c3f Mon Sep 17 00:00:00 2001
From: Yannick Lecaillez <yannick.lecaillez@forgerock.com>
Date: Mon, 07 Nov 2016 13:59:40 +0000
Subject: [PATCH] OPENDJ-3179: Migrate LDAP Connection Handler to SDK Grizzly transport
---
opendj-grizzly/src/main/java/com/forgerock/opendj/grizzly/GrizzlyTransportProvider.java | 16 ++++++++++++++--
1 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/opendj-grizzly/src/main/java/com/forgerock/opendj/grizzly/GrizzlyTransportProvider.java b/opendj-grizzly/src/main/java/com/forgerock/opendj/grizzly/GrizzlyTransportProvider.java
index e67b849..c2dce7e 100644
--- a/opendj-grizzly/src/main/java/com/forgerock/opendj/grizzly/GrizzlyTransportProvider.java
+++ b/opendj-grizzly/src/main/java/com/forgerock/opendj/grizzly/GrizzlyTransportProvider.java
@@ -101,10 +101,22 @@
final ServerConnectionAdaptor<Integer> adapter = new ServerConnectionAdaptor<>(serverConnection);
clientContext.onDisconnect(new DisconnectListener() {
@Override
- public void connectionDisconnected(LDAPClientContext context, ResultCode resultCode, String message) {
- serverConnection.handleConnectionDisconnected(resultCode, message);
+ public void exceptionOccurred(final LDAPClientContext context, final Throwable error) {
+ serverConnection.handleConnectionError(error);
+ }
+
+ @Override
+ public void connectionClosed(final LDAPClientContext context, final UnbindRequest unbindRequest) {
+ serverConnection.handleConnectionClosed(0, unbindRequest);
+ }
+
+ @Override
+ public void connectionDisconnected(final LDAPClientContext context, final ResultCode resultCode,
+ final String diagnosticMessage) {
+ serverConnection.handleConnectionDisconnected(resultCode, diagnosticMessage);
}
});
+
return new ReactiveHandler<LDAPClientContext, LdapRawMessage, Stream<Response>>() {
@Override
public Single<Stream<Response>> handle(final LDAPClientContext context,
--
Gitblit v1.10.0