QPID-4943: Introduce a feature for 0-8/0-9/0-9-1 protocols to close a connection on receiving a mandatory unroutable message in a transacted session

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1495511 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 12 insertions, 3 deletions

diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
index 4e885258b9..74c9878a8e 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
@@ -844,7 +844,7 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect
         }
     }
 
-    public void     close() throws JMSException
+    public void close() throws JMSException
     {
         close(DEFAULT_TIMEOUT);
     }
@@ -859,9 +859,12 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect
         if (!setClosed())
         {
             setClosing(true);
-            try{
+            try
+            {
                 doClose(sessions, timeout);
-            }finally{
+            }
+            finally
+            {
                 setClosing(false);
             }
         }
@@ -1594,4 +1597,10 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect
     {
         return _validateQueueOnSend;
     }
+
+    @Override
+    protected boolean setClosed()
+    {
+        return super.setClosed();
+    }
 }