[rocketmq] branch develop updated: [ISSUE #2821] Overriding the ServiceThread#shutdown in HAClient class

[ji...@apache.org]

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: 灼华 <43...@users.noreply.github.com>
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);