More logging

Author: acogoluegnes

src/main/java/com/rabbitmq/client/amqp/impl/AmqpConnection.java

@@ -292,7 +292,10 @@ TopologyListener createTopologyListener(AmqpConnectionBuilder builder) {
     BiConsumer<org.apache.qpid.protonj2.client.Connection, DisconnectionEvent> result =
         (conn, event) -> {
           ClientIOException ioex = event.failureCause();
-          LOGGER.debug("Disconnect handler, error is the following: {}", ioex.getMessage());
+          LOGGER.debug(
+              "Disconnect handler of '{}', error is the following: {}",
+              this.name(),
+              ioex.getMessage());
           if (this.state() == OPENING) {
             LOGGER.debug("Connection is still opening, disconnect handler skipped");
             // the broker is not available when opening the connection
@@ -301,7 +304,7 @@ TopologyListener createTopologyListener(AmqpConnectionBuilder builder) {
           }
           if (this.recoveringConnection.get()) {
             LOGGER.debug(
-                "Filtering recovery task enqueueing, connection recovery of '{}' in progress",
+                "Filtering recovery task enqueueing, connection recovery of '{}' already in progress",
                 this.name());
             return;
           }
@@ -336,18 +339,21 @@ private void recoverAfterConnectionFailure(
       AtomicReference<BiConsumer<org.apache.qpid.protonj2.client.Connection, DisconnectionEvent>>
           disconnectedHandlerReference) {
     LOGGER.info(
-        "Connection '{}' to '{}' has been disconnected, trying to recover",
+        "Connection '{}' to '{}' has been disconnected, trying to recover.",
         this.name(),
         this.currentConnectionLabel());
+    LOGGER.debug("Notifying listeners of connection '{}'.", this.name());
     this.state(RECOVERING, failureCause);
     this.changeStateOfPublishers(RECOVERING, failureCause);
     this.changeStateOfConsumers(RECOVERING, failureCause);
     this.nativeConnection = null;
     this.nativeSession = null;
     this.connectionAddress = null;
+    LOGGER.debug("Releasing management resource of connection '{}'.", this.name());
     this.releaseManagementResources();
     try {
       this.recoveringConnection.set(true);
+      LOGGER.debug("Connection attempt for '{}'.", this.name());
       NativeConnectionWrapper ncw =
           recoverNativeConnection(
               recoveryConfiguration, connectionName, disconnectedHandlerReference);