Skip to content

Commit 2550d8e

Browse files
authored
Connection is already closed fix (#3587)
1 parent 31a0fdc commit 2550d8e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/producer/CanalRabbitMQProducer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -175,8 +175,8 @@ private void sendMessage(String queueName, byte[] message) {
175175
public void stop() {
176176
logger.info("## Stop RabbitMQ producer##");
177177
try {
178-
this.connect.close();
179178
this.channel.close();
179+
this.connect.close();
180180
super.stop();
181181
} catch (AlreadyClosedException ex) {
182182
logger.error("Connection is already closed", ex);

0 commit comments

Comments
 (0)