From 2550d8eb65aec2e772b9ee799d5d7db81f0fba5e Mon Sep 17 00:00:00 2001
From: dinosaur <thedinosaurmail@gmail.com>
Date: Sat, 9 Oct 2021 14:54:05 +0800
Subject: [PATCH] Connection is already closed  fix (#3587)

---
 .../connector/rabbitmq/producer/CanalRabbitMQProducer.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/producer/CanalRabbitMQProducer.java b/connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/producer/CanalRabbitMQProducer.java
index 07596586..a9905746 100644
--- a/connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/producer/CanalRabbitMQProducer.java
+++ b/connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/producer/CanalRabbitMQProducer.java
@@ -175,8 +175,8 @@ public class CanalRabbitMQProducer extends AbstractMQProducer implements CanalMQ
     public void stop() {
         logger.info("## Stop RabbitMQ producer##");
         try {
-            this.connect.close();
             this.channel.close();
+            this.connect.close();
             super.stop();
         } catch (AlreadyClosedException ex) {
             logger.error("Connection is already closed", ex);