1 files changed, 11 insertions, 1 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/Subscription.java b/java/broker/src/main/java/org/apache/qpid/server/queue/Subscription.java
index fa70c6dbac..e9f209839a 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/queue/Subscription.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/Subscription.java
@@ -38,13 +38,23 @@ public interface Subscription
 
     Queue<AMQMessage> getPreDeliveryQueue();
 
-    void enqueueForPreDelivery(AMQMessage msg);
+    Queue<AMQMessage> getResendQueue();
+
+    Queue<AMQMessage> getNextQueue(Queue<AMQMessage> messages);    
+
+    void enqueueForPreDelivery(AMQMessage msg, boolean deliverFirst);
 
     boolean isAutoClose();
 
     void close();
 
+    boolean isClosed();
+
     boolean isBrowser();
 
     boolean wouldSuspend(AMQMessage msg);
+
+    void addToResendQueue(AMQMessage msg);
+
+    Object getSendLock();
 }