QPID-6063: [Java Broker] Address review comments from Oleksandr Rudyy <orudyy@apache.org>

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622162 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 16 insertions, 23 deletions

diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHARemoteReplicationNodeImpl.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHARemoteReplicationNodeImpl.java
index 3bef144d2d..537c89bfc7 100644
--- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHARemoteReplicationNodeImpl.java
+++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHARemoteReplicationNodeImpl.java
@@ -62,7 +62,6 @@ public class BDBHARemoteReplicationNodeImpl extends AbstractConfiguredObject<BDB
 
     private final AtomicReference<State> _state;
     private final boolean _isMonitor;
-    private boolean _detached;
     private BDBHAVirtualHostNodeLogSubject _virtualHostNodeLogSubject;
     private GroupLogSubject _groupLogSubject;
     private volatile NodeRole _lastKnownRole;
@@ -254,16 +253,6 @@ public class BDBHARemoteReplicationNodeImpl extends AbstractConfiguredObject<BDB
         _state.compareAndSet(currentState, isActive ? State.ACTIVE : State.UNAVAILABLE);
     }
 
-    public boolean isDetached()
-    {
-        return _detached;
-    }
-
-    public void setDetached(boolean detached)
-    {
-        _detached = detached;
-    }
-
     @Override
     public void onValidate()
     {
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNodeImpl.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNodeImpl.java
index 5b81e6eccf..dd7f99c8d4 100644
--- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNodeImpl.java
+++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNodeImpl.java
@@ -118,7 +118,6 @@ public class BDBHAVirtualHostNodeImpl extends AbstractVirtualHostNode<BDBHAVirtu
     @ManagedAttributeField(afterSet="postSetPriority")
     private int _priority;
 
-
     @ManagedAttributeField(afterSet="postSetQuorumOverride")
     private int _quorumOverride;
 
@@ -867,15 +866,16 @@ public class BDBHAVirtualHostNodeImpl extends AbstractVirtualHostNode<BDBHAVirtu
             BDBHARemoteReplicationNodeImpl remoteNode = getChildByName(BDBHARemoteReplicationNodeImpl.class, node.getName());
             if (remoteNode != null)
             {
-                NodeRole currentRole = remoteNode.getRole();
+                final NodeRole previousRole = remoteNode.getRole();
+                final NodeRole newRole;
                 if (nodeState == null)
                 {
-                    remoteNode.setRole(NodeRole.UNREACHABLE);
+                    newRole = NodeRole.UNREACHABLE;
+                    remoteNode.setRole(newRole);
                     remoteNode.setLastTransactionId(-1);
-                    if (!remoteNode.isDetached())
+                    if (previousRole != NodeRole.UNREACHABLE)
                     {
                         getEventLogger().message(getGroupLogSubject(), HighAvailabilityMessages.LEFT(remoteNode.getName(), remoteNode.getAddress()));
-                        remoteNode.setDetached(true);
                     }
                 }
                 else
@@ -883,13 +883,15 @@ public class BDBHAVirtualHostNodeImpl extends AbstractVirtualHostNode<BDBHAVirtu
                     remoteNode.setJoinTime(nodeState.getJoinTime());
                     remoteNode.setLastTransactionId(nodeState.getCurrentTxnEndVLSN());
                     ReplicatedEnvironment.State state = nodeState.getNodeState();
-                    remoteNode.setRole(NodeRole.fromJeState(state));
-                    if (remoteNode.isDetached())
+                    newRole = NodeRole.fromJeState(state);
+                    remoteNode.setRole(newRole);
+
+                    if (previousRole == NodeRole.UNREACHABLE)
                     {
                         getEventLogger().message(getGroupLogSubject(), HighAvailabilityMessages.JOINED(remoteNode.getName(), remoteNode.getAddress()));
-                        remoteNode.setDetached(false);
                     }
-                    if (ReplicatedEnvironment.State.MASTER.name().equals(remoteNode.getRole()))
+
+                    if (NodeRole.MASTER == newRole)
                     {
                         byte[] applicationState = nodeState.getAppState();
                         Set<String> permittedNodes = ReplicatedEnvironmentFacade.convertApplicationStateBytesToPermittedNodeList(applicationState);
@@ -908,10 +910,12 @@ public class BDBHAVirtualHostNodeImpl extends AbstractVirtualHostNode<BDBHAVirtu
                     }
                 }
 
-                NodeRole newRole = remoteNode.getRole();
-                if (newRole != currentRole)
+                if (newRole != previousRole)
                 {
-                    getEventLogger().message(getGroupLogSubject(), HighAvailabilityMessages.ROLE_CHANGED(remoteNode.getName(), remoteNode.getAddress(), currentRole.name(), newRole.name()));
+                    getEventLogger().message(getGroupLogSubject(), HighAvailabilityMessages.ROLE_CHANGED(remoteNode.getName(),
+                                                                                                         remoteNode.getAddress(),
+                                                                                                         previousRole.name(),
+                                                                                                         newRole.name()));
                 }
             }
         }