[activemq-artemis] 02/02: ARTEMIS-2969 / ARTEMIS-2937 RedoConnection should call protonRemotingConnection.destroy

[clebertsuconic]

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git

commit fa4064cfd784e93a02a3905b16b8c9302fe105fc
Author: Clebert Suconic <clebertsuco...@apache.org>
AuthorDate: Mon Nov 2 11:16:36 2020 -0500

    ARTEMIS-2969 / ARTEMIS-2937 RedoConnection should call 
protonRemotingConnection.destroy
    
    Instead of calling destroy, redo was closing the Netty connection directly 
leaving the job of destroy delayed until TTL
---
 .../artemis/protocol/amqp/connect/AMQPBrokerConnection.java      | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
index 1e6d52b..b4b336d 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
@@ -524,15 +524,18 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
       // keeping a single executor thread to this purpose would simplify things
       connectExecutor.execute(() -> {
          if (connecting) {
-            logger.debug("Broker connection " + this.getName() + " was already 
in retry mode, exception or retry no captured");
+            if (logger.isDebugEnabled()) {
+               logger.debug("Broker connection " + this.getName() + " was 
already in retry mode, exception or retry not captured");
+            }
             return;
          }
          connecting = true;
 
          try {
-            if (connection != null) {
-               connection.close();
+            if (protonRemotingConnection != null) {
+               protonRemotingConnection.destroy();
                connection = null;
+               protonRemotingConnection = null;
             }
          } catch (Throwable e) {
             logger.warn(e.getMessage(), e);