1 files changed, 23 insertions, 7 deletions

diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQSessionModel.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQSessionModel.java
index fa171815ca..a8f62b0fa2 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQSessionModel.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQSessionModel.java
@@ -37,26 +37,26 @@ import org.apache.qpid.server.queue.SimpleAMQQueue;
 public interface AMQSessionModel extends Comparable<AMQSessionModel>
 {
     /** Unique session ID across entire broker*/
-    public UUID getId();
+    public UUID getQMFId();
 
     public AMQConnectionModel getConnectionModel();
 
     public String getClientID();
-    
+
     public void close() throws AMQException;
 
     public LogSubject getLogSubject();
-    
+
     /**
      * This method is called from the housekeeping thread to check the status of
      * transactions on this session and react appropriately.
-     * 
+     *
      * If a transaction is open for too long or idle for too long then a warning
      * is logged or the connection is closed, depending on the configuration. An open
      * transaction is one that has recent activity. The transaction age is counted
-     * from the time the transaction was started. An idle transaction is one that 
-     * has had no activity, such as publishing or acknowledgeing messages.
-     * 
+     * from the time the transaction was started. An idle transaction is one that
+     * has had no activity, such as publishing or acknowledging messages.
+     *
      * @param openWarn time in milliseconds before alerting on open transaction
      * @param openClose time in milliseconds before closing connection with open transaction
      * @param idleWarn time in milliseconds before alerting on idle transaction
@@ -68,6 +68,22 @@ public interface AMQSessionModel extends Comparable<AMQSessionModel>
 
     void unblock(AMQQueue queue);
 
+    void block();
+
+    void unblock();
+
+    boolean getBlocking();
 
     boolean onSameConnection(InboundMessage inbound);
+
+    int getUnacknowledgedMessageCount();
+
+    Long getTxnCount();
+    Long getTxnStart();
+    Long getTxnCommits();
+    Long getTxnRejects();
+
+    int getChannelId();
+
+    int getConsumerCount();
 }