mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-31 02:20:15 +08:00
[ISSUE #2821] Overriding the ServiceThread#shutdown in HAClient class
This commit is contained in:
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user