summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
diff options
context:
space:
mode:
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.java3
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;
}
+
}