This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new b4cee1b [ISSUE #2821] Overriding the ServiceThread#shutdown in
HAClient class
b4cee1b is described below
commit b4cee1b102585367b2a1e72a4e587b00a13890ab
Author: 灼华 <[email protected]>
AuthorDate: Tue Apr 20 11:54:35 2021 +0800
[ISSUE #2821] Overriding the ServiceThread#shutdown in HAClient class
---
store/src/main/java/org/apache/rocketmq/store/ha/HAService.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
index a0e77fa..34c51eb 100644
--- a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
@@ -590,6 +590,13 @@ public class HAService {
log.info(this.getServiceName() + " service end");
}
+
+ @Override
+ public void shutdown() {
+ super.shutdown();
+ closeMaster();
+ }
+
// private void disableWriteFlag() {
// if (this.socketChannel != null) {
// SelectionKey sk = this.socketChannel.keyFor(this.selector);
