summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-05-09 16:34:53 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-05-09 16:34:53 +0000
commit6ad1270085d8c3c36806697c55eae530adbf5908 (patch)
tree70872a14236200fea91ee68040643d79de6785ed /qpid/java
parent49d68d0a1b2fb706ca8d356bb7cde5d1e6e86778 (diff)
downloadqpid-python-6ad1270085d8c3c36806697c55eae530adbf5908.tar.gz
QPID-5574 : [Java Broker] remove redundant state transitions
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1593576 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java5
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileBasedGroupProviderImpl.java12
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileSystemPreferencesProviderImpl.java11
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/port/AbstractPort.java18
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AbstractAuthenticationManager.java9
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java11
-rw-r--r--qpid/java/broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/plugins/ACLFileAccessControlProviderImpl.java9
-rw-r--r--qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java7
-rw-r--r--qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/JMXManagementPluginImpl.java7
9 files changed, 17 insertions, 72 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java
index 826917a848..e67191b744 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java
@@ -1097,11 +1097,6 @@ public abstract class AbstractConfiguredObject<X extends ConfiguredObject<X>> im
}
- public final void quiesce()
- {
- setDesiredState(State.QUIESCED);
- }
-
public final void stop()
{
setDesiredState(State.STOPPED);
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileBasedGroupProviderImpl.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileBasedGroupProviderImpl.java
index e2893e57e4..c576fa4e25 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileBasedGroupProviderImpl.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileBasedGroupProviderImpl.java
@@ -270,7 +270,7 @@ public class FileBasedGroupProviderImpl
return _broker.getSecurityManager();
}
- @StateTransition( currentState = { State.UNINITIALIZED, State.QUIESCED, State.STOPPED }, desiredState = State.ACTIVE )
+ @StateTransition( currentState = { State.UNINITIALIZED, State.QUIESCED }, desiredState = State.ACTIVE )
private void activate()
{
try
@@ -288,7 +288,7 @@ public class FileBasedGroupProviderImpl
}
}
- @StateTransition( currentState = { State.QUIESCED, State.ACTIVE, State.STOPPED, State.ERRORED}, desiredState = State.DELETED )
+ @StateTransition( currentState = { State.QUIESCED, State.ACTIVE, State.ERRORED}, desiredState = State.DELETED )
private void doDelete()
{
File file = new File(getPath());
@@ -304,14 +304,6 @@ public class FileBasedGroupProviderImpl
_state.set(State.DELETED);
}
-
- @StateTransition( currentState = { State.UNINITIALIZED, State.ACTIVE, State.QUIESCED}, desiredState = State.STOPPED )
- private void doStop()
- {
- // TODO - this seem inadequate :-)
- _state.set(State.STOPPED);
- }
-
@StateTransition( currentState = State.UNINITIALIZED, desiredState = State.QUIESCED)
private void startQuiesced()
{
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileSystemPreferencesProviderImpl.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileSystemPreferencesProviderImpl.java
index bb9d5c9ce5..7d594af9c2 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileSystemPreferencesProviderImpl.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileSystemPreferencesProviderImpl.java
@@ -132,13 +132,6 @@ public class FileSystemPreferencesProviderImpl
return super.getAttribute(name);
}
- @StateTransition(currentState = { State.ACTIVE, State.QUIESCED }, desiredState = State.STOPPED)
- private void doStop()
- {
- close();
- _state = State.STOPPED;
- }
-
protected void onClose()
{
if(_store != null)
@@ -157,7 +150,7 @@ public class FileSystemPreferencesProviderImpl
_state = State.QUIESCED;
}
- @StateTransition(currentState = { State.ACTIVE, State.QUIESCED, State.STOPPED, State.ERRORED }, desiredState = State.DELETED )
+ @StateTransition(currentState = { State.ACTIVE, State.QUIESCED, State.ERRORED }, desiredState = State.DELETED )
private void doDelete()
{
close();
@@ -172,7 +165,7 @@ public class FileSystemPreferencesProviderImpl
_state = State.DELETED;
}
- @StateTransition(currentState = { State.QUIESCED, State.STOPPED, State.ERRORED }, desiredState = State.ACTIVE )
+ @StateTransition(currentState = { State.QUIESCED, State.ERRORED }, desiredState = State.ACTIVE )
private void restart()
{
_store.open();
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/port/AbstractPort.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/port/AbstractPort.java
index ac1944e4b9..32587c0f4e 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/port/AbstractPort.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/port/AbstractPort.java
@@ -293,21 +293,14 @@ abstract public class AbstractPort<X extends AbstractPort<X>> extends AbstractCo
return super.getAttribute(name);
}
- @StateTransition(currentState = { State.ACTIVE, State.QUIESCED, State.STOPPED, State.ERRORED}, desiredState = State.DELETED )
+ @StateTransition(currentState = { State.ACTIVE, State.QUIESCED, State.ERRORED}, desiredState = State.DELETED )
private void doDelete()
{
close();
_state = State.DELETED;
}
- @StateTransition(currentState = { State.ACTIVE, State.QUIESCED, State.ERRORED}, desiredState = State.STOPPED )
- private void doStop()
- {
- close();
- _state = State.STOPPED;
- }
-
- @StateTransition( currentState = {State.UNINITIALIZED, State.QUIESCED, State.STOPPED}, desiredState = State.ACTIVE )
+ @StateTransition( currentState = {State.UNINITIALIZED, State.QUIESCED}, desiredState = State.ACTIVE )
protected void activate()
{
try
@@ -322,6 +315,13 @@ abstract public class AbstractPort<X extends AbstractPort<X>> extends AbstractCo
}
}
+ @StateTransition( currentState = State.UNINITIALIZED, desiredState = State.QUIESCED)
+ private void startQuiesced()
+ {
+ _state = State.QUIESCED;
+ }
+
+
protected State onActivate()
{
// no-op: expected to be overridden by subclass
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AbstractAuthenticationManager.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AbstractAuthenticationManager.java
index bfd1d9c824..597b9e3bb1 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AbstractAuthenticationManager.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AbstractAuthenticationManager.java
@@ -180,13 +180,6 @@ public abstract class AbstractAuthenticationManager<T extends AbstractAuthentica
}
}
- @StateTransition( currentState = { State.ACTIVE, State.QUIESCED, State.ERRORED, State.UNINITIALIZED } , desiredState = State.STOPPED )
- protected void doStop()
- {
- close();
- _state.set(State.STOPPED);
- }
-
@StateTransition( currentState = State.UNINITIALIZED, desiredState = State.QUIESCED )
protected void startQuiesced()
{
@@ -215,7 +208,7 @@ public abstract class AbstractAuthenticationManager<T extends AbstractAuthentica
}
- @StateTransition( currentState = { State.ACTIVE, State.STOPPED, State.QUIESCED, State.ERRORED}, desiredState = State.DELETED)
+ @StateTransition( currentState = { State.ACTIVE, State.QUIESCED, State.ERRORED}, desiredState = State.DELETED)
protected void doDelete()
{
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
index 9009a9b412..159c526594 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
@@ -702,13 +702,6 @@ public abstract class AbstractVirtualHost<X extends AbstractVirtualHost<X>> exte
return _broker.getSecurityManager();
}
- @StateTransition( currentState = { State.ACTIVE, State.QUIESCED, State.ERRORED}, desiredState = State.STOPPED )
- public void doStop()
- {
- close();
- _state = VirtualHostState.STOPPED;
- }
-
protected void onClose()
{
//Stop Connections
@@ -1252,7 +1245,7 @@ public abstract class AbstractVirtualHost<X extends AbstractVirtualHost<X>> exte
return _housekeepingThreadCount;
}
- @StateTransition( currentState = { State.ACTIVE, State.QUIESCED, State.ERRORED, State.STOPPED}, desiredState = State.DELETED )
+ @StateTransition( currentState = { State.ACTIVE, State.QUIESCED, State.ERRORED }, desiredState = State.DELETED )
private void doDelete()
{
if(_deleted.compareAndSet(false,true))
@@ -1439,7 +1432,7 @@ public abstract class AbstractVirtualHost<X extends AbstractVirtualHost<X>> exte
getDurableConfigurationStore().create(new ConfiguredObjectRecordImpl(record.getId(), record.getType(), record.getAttributes()));
}
- @StateTransition( currentState = {State.UNINITIALIZED, State.STOPPED, State.ERRORED, State.QUIESCED}, desiredState = State.ACTIVE )
+ @StateTransition( currentState = {State.UNINITIALIZED, State.ERRORED, State.QUIESCED}, desiredState = State.ACTIVE )
protected void activate()
{
_houseKeepingTasks = new ScheduledThreadPoolExecutor(getHousekeepingThreadCount());
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 0b31bdbc14..5708e27e33 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
@@ -140,13 +140,6 @@ public class ACLFileAccessControlProviderImpl
}
}
- @StateTransition(currentState = {State.ACTIVE, State.QUIESCED}, desiredState = State.STOPPED)
- private void doStop()
- {
- close();
- _state.set(State.STOPPED);
- }
-
@Override
protected void onClose()
{
@@ -160,7 +153,7 @@ public class ACLFileAccessControlProviderImpl
_state.set(State.QUIESCED);
}
- @StateTransition(currentState = {State.ACTIVE, State.QUIESCED, State.STOPPED, State.ERRORED}, desiredState = State.DELETED)
+ @StateTransition(currentState = {State.ACTIVE, State.QUIESCED, State.ERRORED}, desiredState = State.DELETED)
private void doDelete()
{
close();
diff --git a/qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java b/qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java
index 881d359e9b..47a62f2962 100644
--- a/qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java
+++ b/qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java
@@ -136,13 +136,6 @@ public class HttpManagement extends AbstractPluginAdapter<HttpManagement> implem
setCurrentState(State.ACTIVE);
}
- @StateTransition(currentState = State.ACTIVE, desiredState = State.STOPPED)
- private void doStop()
- {
- close();
- setCurrentState(State.STOPPED);
- }
-
@Override
protected void onClose()
{
diff --git a/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/JMXManagementPluginImpl.java b/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/JMXManagementPluginImpl.java
index 9d1cd8df59..4b4b78decc 100644
--- a/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/JMXManagementPluginImpl.java
+++ b/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/JMXManagementPluginImpl.java
@@ -221,13 +221,6 @@ public class JMXManagementPluginImpl
return port.getAvailableProtocols().contains(Protocol.RMI);
}
- @StateTransition( currentState = State.ACTIVE, desiredState = State.STOPPED )
- private void doStop()
- {
- close();
- setCurrentState(State.STOPPED);
- }
-
@Override
protected void onClose()
{