From 8d3674be3dca57761bee85ba286419f5d339d418 Mon Sep 17 00:00:00 2001 From: gtully Date: Tue, 15 May 2018 14:55:02 +0100 Subject: [PATCH] AMQ-6707 - remove duplicated started state flag --- .../broker/region/cursors/AbstractPendingMessageCursor.java | 2 +- .../apache/activemq/broker/region/cursors/StoreQueueCursor.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) 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 8a1587b3cb..83465a1f16 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; 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 7f26b43cc1..0f7216cb87 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; /**