2 files changed, 7 insertions, 1 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 1f61e0d218..23b47c8d67 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
@@ -578,6 +578,7 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect
 
     public ProtocolVersion makeBrokerConnection(BrokerDetails brokerDetail) throws IOException, AMQException
     {
+        resetClosedFlag();
         return _delegate.makeBrokerConnection(brokerDetail);
     }
 
diff --git a/java/client/src/main/java/org/apache/qpid/client/Closeable.java b/java/client/src/main/java/org/apache/qpid/client/Closeable.java
index ba26bfc485..2f7fbad30c 100644
--- a/java/client/src/main/java/org/apache/qpid/client/Closeable.java
+++ b/java/client/src/main/java/org/apache/qpid/client/Closeable.java
@@ -81,7 +81,7 @@ public abstract class Closeable
     }
 
     /**
-     * Checks if this is closis.
+     * Checks if this is closing.
      *
      * @return <tt>true</tt> if we are closing, <tt>false</tt> otherwise.
      */
@@ -90,6 +90,11 @@ public abstract class Closeable
         return _closing.get();
     }
 
+    public void resetClosedFlag()
+    {
+        _closed.set(false);
+    }
+
     protected boolean setClosed()
     {
         return _closed.getAndSet(true);