mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

pgamba
14.37.2009 4fe72a4bef946169b0f50bc05bd9dc3b4b1131d3
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)
          {
            /*