From b7dde5b118fe17e86a65bb53c35322d2ba64aa55 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Mon, 05 Aug 2013 15:03:12 +0000
Subject: [PATCH] Code cleanup.
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/ExternalChangeLogSessionImpl.java | 17 ++++++-----------
1 files changed, 6 insertions(+), 11 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ExternalChangeLogSessionImpl.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ExternalChangeLogSessionImpl.java
index 7584a5d..45cd93b 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ExternalChangeLogSessionImpl.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ExternalChangeLogSessionImpl.java
@@ -23,11 +23,10 @@
*
*
* Copyright 2009-2010 Sun Microsystems, Inc.
- * Portions Copyright 2012 ForgeRock AS
+ * Portions Copyright 2012-2013 ForgeRock AS
*/
package org.opends.server.replication.server;
-
import org.opends.server.replication.common.ExternalChangeLogSession;
import org.opends.server.replication.protocol.ECLUpdateMsg;
import org.opends.server.replication.protocol.StartECLSessionMsg;
@@ -37,12 +36,10 @@
* This class implements a session used to search the external changelog
* in the Directory Server.
*/
-public class ExternalChangeLogSessionImpl
- implements ExternalChangeLogSession
+public class ExternalChangeLogSessionImpl implements ExternalChangeLogSession
{
- ECLServerHandler handler;
-
+ private ECLServerHandler handler;
/**
* Create a new external changelog session.
@@ -56,11 +53,7 @@
StartECLSessionMsg startECLSessionMsg)
throws DirectoryException
{
- this.handler = new ECLServerHandler(
- rs.getServerURL(),
- rs.getServerId(),
- rs,
- startECLSessionMsg);
+ this.handler = new ECLServerHandler(rs, startECLSessionMsg);
}
/**
@@ -69,6 +62,7 @@
* @return the next available message from the ECL.
* @throws DirectoryException when needed.
*/
+ @Override
public ECLUpdateMsg getNextUpdate()
throws DirectoryException
{
@@ -78,6 +72,7 @@
/**
* Close the session.
*/
+ @Override
public void close()
{
// ECL is a special case in the sense that there is no
--
Gitblit v1.10.0