From 62c7d9970ee34d102a78ce72a459274a97721cc6 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Fri, 06 Jun 2014 14:50:38 +0000
Subject: [PATCH] OPENDJ-1453 (CR-3697) Change time heart beat change numbers should be synced with updates
---
opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationDomain.java | 12 +++++++++---
1 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationDomain.java b/opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationDomain.java
index de653f3..ce9d714 100644
--- a/opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationDomain.java
+++ b/opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationDomain.java
@@ -210,7 +210,7 @@
/**
* Current status for this replicated domain.
*/
- protected ServerStatus status = ServerStatus.NOT_CONNECTED_STATUS;
+ private ServerStatus status = ServerStatus.NOT_CONNECTED_STATUS;
private static final LocalizedLogger logger = LocalizedLogger.getLoggerForThisClass();
/** The configuration of the replication domain. */
@@ -2432,7 +2432,13 @@
* event.
* @param event The event that may make the status be changed
*/
- protected void setNewStatus(StatusMachineEvent event)
+ protected void signalNewStatus(StatusMachineEvent event)
+ {
+ setNewStatus(event);
+ broker.signalStatusChange(status);
+ }
+
+ private void setNewStatus(StatusMachineEvent event)
{
ServerStatus newStatus = StatusMachine.computeNewStatus(status, event);
if (newStatus == ServerStatus.INVALID_STATUS)
@@ -3400,7 +3406,7 @@
* receive this {@link UpdateMsg} through a call of the
* {@link #processUpdate(UpdateMsg)} message.
*
- * @param msg The UpdateMsg that should be pushed.
+ * @param msg The UpdateMsg that should be published.
*/
public void publish(UpdateMsg msg)
{
--
Gitblit v1.10.0