Clean up connection resources on failed connect.

activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/client/AmqpConnection.java

@@ -165,6 +165,7 @@ public class AmqpConnection extends AmqpAbstractResource<Connection> implements
                 }
             });
 
+            try {
                 if (connectTimeout <= 0) {
                     future.sync();
                 } else {
@@ -173,6 +174,13 @@ public class AmqpConnection extends AmqpAbstractResource<Connection> implements
                         throw new IOException("Failed to connect after configured timeout.");
                     }
                 }
+            } catch (Throwable error) {
+                try {
+                    close();
+                } catch (Throwable ignore) {}
+
+                throw error;
+            }
         }
     }