1 files changed, 8 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription.java
index 5c4e413989..bc1be90531 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription.java
@@ -69,17 +69,24 @@ public interface Subscription
 
     void close();
 
-    void send(QueueEntry msg) throws AMQException;
+    void send(QueueEntry entry, boolean batch) throws AMQException;
+
+    void flushBatched();
 
     void queueDeleted(AMQQueue queue);
 
 
     boolean wouldSuspend(QueueEntry msg);
 
+    boolean trySendLock();
+
+
     void getSendLock();
 
     void releaseSendLock();
 
+    void releaseQueueEntry(final QueueEntry queueEntryImpl);
+
     void onDequeue(final QueueEntry queueEntry);
 
     void restoreCredit(final QueueEntry queueEntry);