From 4fe72a4bef946169b0f50bc05bd9dc3b4b1131d3 Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Fri, 14 Aug 2009 12:37:19 +0000
Subject: [PATCH] Support for External change log compatible with draft-good-ldap-changelog-04.txt , March 2003
---
opends/src/server/org/opends/server/replication/server/ServerHandler.java | 11 ++++-------
1 files changed, 4 insertions(+), 7 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ServerHandler.java b/opends/src/server/org/opends/server/replication/server/ServerHandler.java
index 384dcae..90e593b 100644
--- a/opends/src/server/org/opends/server/replication/server/ServerHandler.java
+++ b/opends/src/server/org/opends/server/replication/server/ServerHandler.java
@@ -46,13 +46,13 @@
import org.opends.server.replication.common.ChangeNumber;
import org.opends.server.replication.common.RSInfo;
import org.opends.server.replication.common.ServerStatus;
+import org.opends.server.replication.protocol.ReplicationMsg;
import org.opends.server.replication.protocol.AckMsg;
import org.opends.server.replication.protocol.ErrorMsg;
import org.opends.server.replication.protocol.HeartbeatThread;
import org.opends.server.replication.protocol.ProtocolSession;
import org.opends.server.replication.protocol.ProtocolVersion;
import org.opends.server.replication.protocol.ReplServerStartMsg;
-import org.opends.server.replication.protocol.ResetGenerationIdMsg;
import org.opends.server.replication.protocol.RoutableMsg;
import org.opends.server.replication.protocol.StartECLSessionMsg;
import org.opends.server.replication.protocol.StartMsg;
@@ -389,14 +389,12 @@
}
/**
- * Sends a message containing a generationId to a peer server.
- * The peer is expected to be a replication server.
- *
- * @param msg The GenerationIdMessage message to be sent.
+ * Sends a message.
+ * @param msg The message to be sent.
* @throws IOException When it occurs while sending the message,
*
*/
- public void forwardGenerationIdToRS(ResetGenerationIdMsg msg)
+ public void send(ReplicationMsg msg)
throws IOException
{
session.publish(msg);
@@ -1352,5 +1350,4 @@
inStartECLSessionMsg.toString());
}
}
-
}
--
Gitblit v1.10.0