You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2018/05/15 13:56:22 UTC
activemq git commit: AMQ-6707 - remove duplicated started state flag
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 <ga...@gmail.com>
Authored: Tue May 15 14:55:02 2018 +0100
Committer: gtully <ga...@gmail.com>
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;
/**