From 2942eaa1b7264228c9ca7535aabd206e663581e9 Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Thu, 03 Jan 2008 09:41:49 +0000
Subject: [PATCH]
---
opends/src/server/org/opends/server/replication/server/ServerReader.java | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 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 b1071ff..9193c99 100644
--- a/opends/src/server/org/opends/server/replication/server/ServerReader.java
+++ b/opends/src/server/org/opends/server/replication/server/ServerReader.java
@@ -22,7 +22,7 @@
* CDDL HEADER END
*
*
- * Portions Copyright 2006-2007 Sun Microsystems, Inc.
+ * Portions Copyright 2006-2008 Sun Microsystems, Inc.
*/
package org.opends.server.replication.server;
import org.opends.messages.Message;
@@ -49,6 +49,8 @@
import org.opends.server.replication.protocol.WindowMessage;
import org.opends.server.replication.protocol.WindowProbe;
import org.opends.server.replication.protocol.ReplServerInfoMessage;
+import org.opends.server.replication.protocol.MonitorMessage;
+import org.opends.server.replication.protocol.MonitorRequestMessage;
import org.opends.server.loggers.debug.DebugTracer;
@@ -246,6 +248,17 @@
}
}
}
+ else if (msg instanceof MonitorRequestMessage)
+ {
+ MonitorRequestMessage replServerMonitorRequestMsg =
+ (MonitorRequestMessage) msg;
+ handler.process(replServerMonitorRequestMsg);
+ }
+ else if (msg instanceof MonitorMessage)
+ {
+ MonitorMessage replServerMonitorMsg = (MonitorMessage) msg;
+ handler.process(replServerMonitorMsg);
+ }
else if (msg == null)
{
/*
--
Gitblit v1.10.0