summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/access-control/src
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/broker-plugins/access-control/src')
-rw-r--r--qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/ACLFileAccessControlProviderImpl.java18
1 files changed, 5 insertions, 13 deletions
diff --git a/qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/ACLFileAccessControlProviderImpl.java b/qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/ACLFileAccessControlProviderImpl.java
index 5708e27e33..f0edc59025 100644
--- a/qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/ACLFileAccessControlProviderImpl.java
+++ b/qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/ACLFileAccessControlProviderImpl.java
@@ -49,8 +49,6 @@ public class ACLFileAccessControlProviderImpl
protected DefaultAccessControl _accessControl;
protected final Broker _broker;
- private AtomicReference<State> _state = new AtomicReference<>(State.UNINITIALIZED);
-
@ManagedAttributeField
private String _path;
@@ -98,12 +96,6 @@ public class ACLFileAccessControlProviderImpl
}
@Override
- public State getState()
- {
- return _state.get();
- }
-
- @Override
public <C extends ConfiguredObject> Collection<C> getChildren(Class<C> clazz)
{
return Collections.emptySet();
@@ -116,18 +108,18 @@ public class ACLFileAccessControlProviderImpl
if(_broker.isManagementMode())
{
- _state.set(_accessControl.validate() ? State.QUIESCED : State.ERRORED);
+ setState(_accessControl.validate() ? State.QUIESCED : State.ERRORED);
}
else
{
try
{
_accessControl.open();
- _state.set(State.ACTIVE);
+ setState(State.ACTIVE);
}
catch (RuntimeException e)
{
- _state.set(State.ERRORED);
+ setState(State.ERRORED);
if (_broker.isManagementMode())
{
LOGGER.warn("Failed to activate ACL provider: " + getName(), e);
@@ -150,14 +142,14 @@ public class ACLFileAccessControlProviderImpl
@StateTransition(currentState = State.UNINITIALIZED, desiredState = State.QUIESCED)
private void startQuiesced()
{
- _state.set(State.QUIESCED);
+ setState(State.QUIESCED);
}
@StateTransition(currentState = {State.ACTIVE, State.QUIESCED, State.ERRORED}, desiredState = State.DELETED)
private void doDelete()
{
close();
- _state.set(State.DELETED);
+ setState(State.DELETED);
deleted();
}