You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 03:39:34 UTC
[rocketmq-connect] 24/39: When replicator stop, stop MQAdminExt and Listener (#474)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 61826240f53dfdf2fa9690d5b89a9ed2fc35d41f
Author: zhoubo <87...@qq.com>
AuthorDate: Fri Nov 29 21:28:53 2019 +0800
When replicator stop, stop MQAdminExt and Listener (#474)
* https://github.com/apache/rocketmq-externals/issues/469
---
.../java/org/apache/rocketmq/replicator/RmqSourceReplicator.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java b/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java
index c560840..e868b89 100644
--- a/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java
+++ b/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java
@@ -170,17 +170,24 @@ public class RmqSourceReplicator extends SourceConnector {
return true;
}
+ @Override
public void stop() {
+ executor.shutdown();
+ this.srcMQAdminExt.shutdown();
+ this.targetMQAdminExt.shutdown();
}
+ @Override
public void pause() {
}
+ @Override
public void resume() {
}
+ @Override
public Class<? extends Task> taskClass() {
return RmqSourceTask.class;