From b63534c2cfcfb43bd090bd94e85c4c89ab5ebcba Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Mon, 17 Aug 2009 10:10:26 +0000
Subject: [PATCH] fix for Replication Service interface compatibility that was just broken by External Changelog last commit - By default, the change time heartbeat mechanism is disabled
---
opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java | 44 ++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 44 insertions(+), 0 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java b/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
index 0c1e208..3a05a7b 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
@@ -2330,6 +2330,50 @@
}
/**
+ * Start the publish mechanism of the Replication Service.
+ * After this method has been called, the publish service can be used
+ * by calling the {@link #publish(UpdateMsg)} method.
+ *
+ * @param replicationServers The replication servers that should be used.
+ * @param window The window size of this replication domain.
+ * @param heartbeatInterval The heartbeatInterval that should be used
+ * to check the availability of the replication
+ * servers.
+ * @throws ConfigException If the DirectoryServer configuration was
+ * incorrect.
+ */
+ public void startPublishService(
+ Collection<String> replicationServers, int window,
+ long heartbeatInterval)
+ throws ConfigException
+ {
+ if (broker == null)
+ {
+ /*
+ * create the broker object used to publish and receive changes
+ */
+ broker = new ReplicationBroker(
+ this, state, serviceID,
+ serverID, window,
+ getGenerationID(),
+ heartbeatInterval,
+ new ReplSessionSecurity(),
+ getGroupId(),
+ 0); // change time heartbeat is disabled
+
+ broker.start(replicationServers);
+
+ /*
+ * Create a replication monitor object responsible for publishing
+ * monitoring information below cn=monitor.
+ */
+ monitor = new ReplicationMonitor(this);
+
+ DirectoryServer.registerMonitorProvider(monitor);
+ }
+ }
+
+ /**
* Starts the receiver side of the Replication Service.
* <p>
* After this method has been called, the Replication Service will start
--
Gitblit v1.10.0