From 6a7fdc04408e52abb5e5cacdc03f51a8e995d5cf Mon Sep 17 00:00:00 2001
From: Matthew Swift <matthew.swift@forgerock.com>
Date: Fri, 01 Apr 2011 20:29:09 +0000
Subject: [PATCH] Fix issue OPENDJ-105: Replication protocol error. Bad message type. org.opends.server.replication.protocol.StopMsg received, ReplServerStartMsg required
---
opends/src/server/org/opends/server/replication/server/ServerReader.java | 16 ++--------------
1 files changed, 2 insertions(+), 14 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ServerReader.java b/opends/src/server/org/opends/server/replication/server/ServerReader.java
index 7517b25..43147e9 100644
--- a/opends/src/server/org/opends/server/replication/server/ServerReader.java
+++ b/opends/src/server/org/opends/server/replication/server/ServerReader.java
@@ -40,7 +40,6 @@
import org.opends.server.loggers.debug.DebugTracer;
import org.opends.server.replication.common.ServerStatus;
import org.opends.server.replication.protocol.*;
-import org.opends.server.types.DebugLogLevel;
/**
* This class implement the part of the replicationServer that is reading
@@ -222,19 +221,8 @@
} else if (msg instanceof TopologyMsg)
{
TopologyMsg topoMsg = (TopologyMsg) msg;
- try
- {
- ReplicationServerHandler rsh = (ReplicationServerHandler)handler;
- rsh.receiveTopoInfoFromRS(topoMsg);
- }
- catch(Exception e)
- {
- TRACER.debugCaught(DebugLogLevel.ERROR, e);
- errMessage =
- ERR_REPLICATION_PROTOCOL_MESSAGE_TYPE.get(
- "TopologyMsg", "other");
- logError(errMessage);
- }
+ ReplicationServerHandler rsh = (ReplicationServerHandler)handler;
+ rsh.receiveTopoInfoFromRS(topoMsg);
} else if (msg instanceof ChangeStatusMsg)
{
ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
--
Gitblit v1.10.0