Repository: activemq Updated Branches: refs/heads/master 09bf8f89b -> 8d3674be3
AMQ-6707 - remove duplicated started state flag Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/8d3674be Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/8d3674be Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/8d3674be Branch: refs/heads/master Commit: 8d3674be3dca57761bee85ba286419f5d339d418 Parents: 09bf8f8 Author: gtully <[email protected]> Authored: Tue May 15 14:55:02 2018 +0100 Committer: gtully <[email protected]> Committed: Tue May 15 14:55:02 2018 +0100 ---------------------------------------------------------------------- .../broker/region/cursors/AbstractPendingMessageCursor.java | 2 +- .../apache/activemq/broker/region/cursors/StoreQueueCursor.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/8d3674be/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java index 8a1587b..83465a1 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java @@ -46,7 +46,7 @@ public abstract class AbstractPendingMessageCursor implements PendingMessageCurs protected ActiveMQMessageAudit audit; protected boolean useCache=true; protected boolean cacheEnabled=true; - private boolean started=false; + protected boolean started=false; protected MessageReference last = null; protected final boolean prioritizedMessages; http://git-wip-us.apache.org/repos/asf/activemq/blob/8d3674be/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java index 7f26b43..0f7216c 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java @@ -35,7 +35,6 @@ public class StoreQueueCursor extends AbstractPendingMessageCursor { private final Queue queue; private PendingMessageCursor nonPersistent; private final QueueStorePrefetch persistent; - private boolean started; private PendingMessageCursor currentCursor; /**
