1 files changed, 0 insertions, 21 deletions
diff --git a/java/broker-core/src/main/java/org/apache/qpid/server/consumer/Consumer.java b/java/broker-core/src/main/java/org/apache/qpid/server/consumer/Consumer.java
index 4c1ebc3547..7f6f7f44e9 100644
--- a/java/broker-core/src/main/java/org/apache/qpid/server/consumer/Consumer.java
+++ b/java/broker-core/src/main/java/org/apache/qpid/server/consumer/Consumer.java
@@ -44,8 +44,6 @@ public interface Consumer
 
     LogActor getLogActor();
 
-    boolean isTransient();
-
     long getBytesOut();
 
     long getMessagesOut();
@@ -63,16 +61,12 @@ public interface Consumer
 
     AMQSessionModel getSessionModel();
 
-    MessageInstance.ConsumerAcquiredState getOwningState();
-
     void setNoLocal(boolean noLocal);
 
     long getId();
 
     boolean isSuspended();
 
-    boolean hasInterest(MessageInstance msg);
-
     boolean isClosed();
 
     boolean acquires();
@@ -81,17 +75,6 @@ public interface Consumer
 
     void close() throws AMQException;
 
-    void send(MessageInstance entry, boolean batch) throws AMQException;
-
-    boolean resend(MessageInstance entry) throws AMQException;
-
-    void flushBatched();
-
-    void queueDeleted();
-
-
-    boolean wouldSuspend(MessageInstance msg);
-
     boolean trySendLock();
 
 
@@ -99,16 +82,12 @@ public interface Consumer
 
     void releaseSendLock();
 
-    void restoreCredit(final MessageInstance queueEntry);
-
     void setStateListener(final StateChangeListener<? extends Consumer, State> listener);
 
     public State getState();
 
     boolean isActive();
 
-    void queueEmpty() throws AMQException;
-
     String getName();
 
     void flush() throws AMQException;