diff options
Diffstat (limited to 'java/broker/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java')
-rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java | 31 |
1 files changed, 20 insertions, 11 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java index 5af3899890..36fafba1cd 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java +++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java @@ -31,24 +31,21 @@ import java.util.UUID; public interface AMQConnectionModel extends StatisticsGatherer { /** - * get a unique id for this connection. - * - * @return a {@link UUID} representing the connection - */ - public UUID getId(); - - /** * Close the underlying Connection - * + * * @param cause * @param message * @throws org.apache.qpid.AMQException */ public void close(AMQConstant cause, String message) throws AMQException; + public void block(); + + public void unblock(); + /** * Close the given requested Session - * + * * @param session * @param cause * @param message @@ -57,10 +54,10 @@ public interface AMQConnectionModel extends StatisticsGatherer public void closeSession(AMQSessionModel session, AMQConstant cause, String message) throws AMQException; public long getConnectionId(); - + /** * Get a list of all sessions using this connection. - * + * * @return a list of {@link AMQSessionModel}s */ public List<AMQSessionModel> getSessionModels(); @@ -73,4 +70,16 @@ public interface AMQConnectionModel extends StatisticsGatherer public String getUserName(); public boolean isSessionNameUnique(byte[] name); + + String getRemoteAddressString(); + + String getClientId(); + + String getClientVersion(); + + String getPrincipalAsString(); + + long getSessionCountLimit(); + + long getLastIoTime(); } |