1 files changed, 3 insertions, 0 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
index 1e8dd9f77a..b15e6a4219 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
@@ -37,6 +37,7 @@ import java.security.Principal;
 
 public interface AMQProtocolSession extends AMQVersionAwareProtocolSession, PrincipalHolder
 {
+    long getSessionID();
 
     public static final class ProtocolSessionIdentifier
     {
@@ -196,6 +197,8 @@ public interface AMQProtocolSession extends AMQVersionAwareProtocolSession, Prin
 
     void setAuthorizedID(Principal authorizedID);
 
+    public java.net.SocketAddress getRemoteAddress();
+
     public MethodRegistry getMethodRegistry();
 
     public MethodDispatcher getMethodDispatcher();