[incubator-iotdb] branch disable_mqtt_server created (now 365c82e)

[hx...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hxd pushed a change to branch disable_mqtt_server
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.


      at 365c82e  close thrift ocne again

This branch includes the following new commits:

     new 365c82e  close thrift ocne again

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[incubator-iotdb] 01/01: close thrift ocne again

[hx...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hxd pushed a commit to branch disable_mqtt_server
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git

commit 365c82e6996844bd07fbc9f5bd2d90bcf07fdc61
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Thu Apr 16 09:13:14 2020 +0800

    close thrift ocne again
---
 server/src/main/java/org/apache/iotdb/db/service/RPCService.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/service/RPCService.java b/server/src/main/java/org/apache/iotdb/db/service/RPCService.java
index bdb6f4d..1782cf9 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/RPCService.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/RPCService.java
@@ -240,6 +240,7 @@ public class RPCService implements RPCServiceMBean, IService {
 
     private synchronized void close() {
       if (poolServer != null) {
+        poolServer.setShouldStop(true);
         poolServer.stop();
         poolServer = null;
       }