From 2d5bedc7a219b43eedbfe33bbe12b750c3fc4519 Mon Sep 17 00:00:00 2001
From: Alex Rudyy <orudyy@apache.org>
Date: Wed, 24 Sep 2014 11:16:23 +0000
Subject: QPID-6114: Migrate the State member variable to
 AbstractConfiguredObject class

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1627278 13f79535-47bb-0310-9956-ffa450edef68
---
 .../virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java   |  7 +------
 .../berkeleydb/BDBHARemoteReplicationNodeImpl.java        | 15 ++++-----------
 2 files changed, 5 insertions(+), 17 deletions(-)

(limited to 'qpid/java/bdbstore/src')

diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java
index 6f03dc51df..58105cddc1 100644
--- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java
+++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java
@@ -94,6 +94,7 @@ public class BDBHAReplicaVirtualHost extends AbstractConfiguredObject<BDBHARepli
         _dataDelivered = new StatisticsCounter("bytes-delivered-" + getName());
         _messagesReceived = new StatisticsCounter("messages-received-" + getName());
         _dataReceived = new StatisticsCounter("bytes-received-" + getName());
+        setState(State.UNAVAILABLE);
     }
 
     @Override
@@ -150,12 +151,6 @@ public class BDBHAReplicaVirtualHost extends AbstractConfiguredObject<BDBHARepli
         throwUnsupportedForReplica();
     }
 
-    @Override
-    public State getState()
-    {
-        return State.UNAVAILABLE;
-    }
-
     @Override
     public Collection<String> getExchangeTypeNames()
     {
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 537c89bfc7..dfbdce4399 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
@@ -60,7 +60,6 @@ public class BDBHARemoteReplicationNodeImpl extends AbstractConfiguredObject<BDB
     @ManagedAttributeField(afterSet="afterSetRole")
     private volatile NodeRole _role;
 
-    private final AtomicReference<State> _state;
     private final boolean _isMonitor;
     private BDBHAVirtualHostNodeLogSubject _virtualHostNodeLogSubject;
     private GroupLogSubject _groupLogSubject;
@@ -72,7 +71,7 @@ public class BDBHARemoteReplicationNodeImpl extends AbstractConfiguredObject<BDB
         _broker = virtualHostNode.getParent(Broker.class);
         _address = (String)attributes.get(ADDRESS);
         _replicatedEnvironmentFacade = replicatedEnvironmentFacade;
-        _state = new AtomicReference<>(State.ACTIVE);
+        setState(State.ACTIVE);
 
         _role = NodeRole.UNREACHABLE;
         _lastKnownRole = NodeRole.UNREACHABLE;
@@ -80,12 +79,6 @@ public class BDBHARemoteReplicationNodeImpl extends AbstractConfiguredObject<BDB
         _isMonitor = (Boolean)attributes.get(MONITOR);
     }
 
-    @Override
-    public State getState()
-    {
-        return _state.get();
-    }
-
     @Override
     public String getGroupName()
     {
@@ -166,7 +159,7 @@ public class BDBHARemoteReplicationNodeImpl extends AbstractConfiguredObject<BDB
         try
         {
             _replicatedEnvironmentFacade.removeNodeFromGroup(nodeName);
-            _state.set(State.DELETED);
+            setState(State.DELETED);
             deleted();
         }
         catch(MasterStateException e)
@@ -243,14 +236,14 @@ public class BDBHARemoteReplicationNodeImpl extends AbstractConfiguredObject<BDB
 
     private void updateModelStateFromRole(NodeRole role)
     {
-        State currentState = _state.get();
+        State currentState = getState();
         if (currentState == State.DELETED)
         {
             return;
         }
 
         boolean isActive = NodeRole.MASTER == role || NodeRole.REPLICA == role;
-        _state.compareAndSet(currentState, isActive ? State.ACTIVE : State.UNAVAILABLE);
+        setState(isActive ? State.ACTIVE : State.UNAVAILABLE);
     }
 
     @Override
-- 
cgit v1.2.1