Skip to content

Commit 6287c81

Browse files
committed
fix bug:do not exit when disconnect called
1 parent d648c71 commit 6287c81

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

chainsql/src/main/java/com/peersafe/base/client/Client.java

+2
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import java.util.logging.Level;
2020
import java.util.logging.Logger;
2121

22+
import com.peersafe.chainsql.manager.CallbackManager;
2223
import org.json.JSONArray;
2324
import org.json.JSONException;
2425
import org.json.JSONObject;
@@ -361,6 +362,7 @@ public void disconnect() {
361362
manuallyDisconnected = true;
362363
disconnectInner();
363364
service.shutdownNow();
365+
CallbackManager.instance().shutdown();
364366
// our disconnect handler should do the rest
365367
}
366368

chainsql/src/main/java/com/peersafe/chainsql/manager/CallbackManager.java

+5-1
Original file line numberDiff line numberDiff line change
@@ -24,5 +24,9 @@ public CallbackManager() {
2424
*/
2525
public void runRunnable(Runnable runnable) {
2626
service.execute(runnable);
27-
}
27+
}
28+
29+
public void shutdown(){
30+
service.shutdown();
31+
}
2832
}

0 commit comments

Comments
 (0)