diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java')
-rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java index 67bc87145a..4f43695b13 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java @@ -46,7 +46,6 @@ public class QueueEntryImpl implements QueueEntry private MessageReference _message; - private Set<Subscription> _rejectedBy = null; private volatile EntryState _state = AVAILABLE_STATE; @@ -198,7 +197,6 @@ public class QueueEntryImpl implements QueueEntry _stateUpdater.set(this,AVAILABLE_STATE); } - public boolean immediateAndNotDelivered() { return getMessage().isImmediate() && !_deliveredToConsumer; @@ -419,4 +417,5 @@ public class QueueEntryImpl implements QueueEntry { return _queueEntryList; } + } |