From 5ec0cb08889c9f1a24fd4cc8b139dcdb942dd92a 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
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerReader.java | 9 ++++++++-
1 files changed, 8 insertions(+), 1 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerReader.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerReader.java
index c128db2..0bae9e6 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerReader.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerReader.java
@@ -52,6 +52,7 @@
import org.opends.server.replication.protocol.TopologyMsg;
import org.opends.server.replication.protocol.MonitorMsg;
import org.opends.server.replication.protocol.MonitorRequestMsg;
+import org.opends.server.replication.protocol.ChangeTimeHeartbeatMsg;
import org.opends.server.loggers.debug.DebugTracer;
import org.opends.server.replication.common.ServerStatus;
import org.opends.server.replication.protocol.ChangeStatusMsg;
@@ -127,7 +128,8 @@
if (debugEnabled())
{
- TRACER.debugInfo(this.getName() + " receives " + msg);
+ TRACER.debugInfo("In " + replicationServerDomain + " " +
+ getName() + " receives " + msg);
}
if (msg instanceof AckMsg)
@@ -282,6 +284,11 @@
{
MonitorMsg replServerMonitorMsg = (MonitorMsg) msg;
handler.process(replServerMonitorMsg);
+ } else if (msg instanceof ChangeTimeHeartbeatMsg)
+ {
+ ChangeTimeHeartbeatMsg cthbMsg = (ChangeTimeHeartbeatMsg) msg;
+ replicationServerDomain.processChangeTimeHeartbeatMsg(handler,
+ cthbMsg);
} else if (msg == null)
{
/*
--
Gitblit v1.10.0