Repository: activemq-artemis Updated Branches: refs/heads/master 31748a793 -> c0f71c3e1
fixing executor (adding state back) Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/c0f71c3e Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/c0f71c3e Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/c0f71c3e Branch: refs/heads/master Commit: c0f71c3e1537da7bafb9071f746cfcb2687778e0 Parents: 31748a7 Author: Clebert Suconic <[email protected]> Authored: Thu Dec 17 22:43:20 2015 -0500 Committer: Clebert Suconic <[email protected]> Committed: Thu Dec 17 22:46:33 2015 -0500 ---------------------------------------------------------------------- .../apache/activemq/artemis/utils/OrderedExecutorFactory.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/c0f71c3e/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java ---------------------------------------------------------------------- diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java index 18db9c7..b1e9d88 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java @@ -62,6 +62,10 @@ public final class OrderedExecutorFactory implements ExecutorFactory { private final Executor delegate; private final ExecutorTask task = new ExecutorTask(); + // used by stateUpdater + @SuppressWarnings("unused") + private volatile int state = 0; + private static final AtomicIntegerFieldUpdater<OrderedExecutor> stateUpdater = AtomicIntegerFieldUpdater.newUpdater(OrderedExecutor.class, "state"); private static final int STATE_NOT_RUNNING = 0;
