|
@@ -175,8 +175,8 @@ public class CanalRabbitMQProducer extends AbstractMQProducer implements CanalMQ
|
|
public void stop() {
|
|
public void stop() {
|
|
logger.info("## Stop RabbitMQ producer##");
|
|
logger.info("## Stop RabbitMQ producer##");
|
|
try {
|
|
try {
|
|
- this.connect.close();
|
|
|
|
this.channel.close();
|
|
this.channel.close();
|
|
|
|
+ this.connect.close();
|
|
super.stop();
|
|
super.stop();
|
|
} catch (AlreadyClosedException ex) {
|
|
} catch (AlreadyClosedException ex) {
|
|
logger.error("Connection is already closed", ex);
|
|
logger.error("Connection is already closed", ex);
|