From 2a6a181b22220724b6a3a68d898f5260e1e884b1 Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Fri, 9 Apr 2010 14:16:08 +0000 Subject: QPID-2379: add Connection.close() method implementation git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@932428 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/transport/Connection.java | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) (limited to 'java/common/src') diff --git a/java/common/src/main/java/org/apache/qpid/transport/Connection.java b/java/common/src/main/java/org/apache/qpid/transport/Connection.java index 2ca5d28f42..1f559f690f 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/Connection.java +++ b/java/common/src/main/java/org/apache/qpid/transport/Connection.java @@ -531,6 +531,16 @@ public class Connection extends ConnectionInvoker } public void close() + { + close(ConnectionCloseCode.NORMAL, null); + } + + public void mgmtClose() + { + close(ConnectionCloseCode.CONNECTION_FORCED, "The connection was closed using the broker's management interface."); + } + + public void close(ConnectionCloseCode replyCode, String replyText, Option ... _options) { synchronized (lock) { @@ -538,7 +548,7 @@ public class Connection extends ConnectionInvoker { case OPEN: state = CLOSING; - connectionClose(ConnectionCloseCode.NORMAL, null); + connectionClose(replyCode, replyText, _options); Waiter w = new Waiter(lock, timeout); while (w.hasTime() && state == CLOSING && error == null) { @@ -547,14 +557,14 @@ public class Connection extends ConnectionInvoker if (error != null) { - close(); + close(replyCode, replyText, _options); throw new ConnectionException(error); } switch (state) { case CLOSING: - close(); + close(replyCode, replyText, _options); throw new ConnectionException("close() timed out"); case CLOSED: break; -- cgit v1.2.1