Skip to content

Commit be6240a

Browse files
chaychen2005chaychen
andauthored
stop event in bcosSDK (#139)
Co-authored-by: chaychen <chaychen@zhangruideMacBook-Air.local>
1 parent 8f2bece commit be6240a

File tree

2 files changed

+10
-3
lines changed

2 files changed

+10
-3
lines changed

sdk-service/src/main/java/org/fisco/bcos/sdk/BcosSDK.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -204,6 +204,10 @@ public void stopAll() {
204204
// stop the client
205205
for (Integer groupId : groupToClient.keySet()) {
206206
groupToClient.get(groupId).stop();
207+
EventSubscribe event = this.getEventSubscribe(groupId);
208+
if (event != null) {
209+
event.stop();
210+
}
207211
}
208212
}
209213
}

sdk-service/src/main/java/org/fisco/bcos/sdk/eventsub/EventSubscribeImp.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -142,10 +142,13 @@ public void start() {
142142

143143
@Override
144144
public void stop() {
145+
if (!running) {
146+
return;
147+
}
145148
running = false;
146149
resendSchedule.shutdown();
147-
// unsubscribe events
148-
List<EventLogFilter> filterList = getAllSubscribedEvent();
150+
// unsubscribe events, fisco bcos 2.7.0
151+
/*List<EventLogFilter> filterList = getAllSubscribedEvent();
149152
for (EventLogFilter filter : filterList) {
150153
EventCallback callback =
151154
new EventCallback() {
@@ -158,7 +161,7 @@ public void onReceiveLog(int status, List<EventLog> logs) {
158161
}
159162
};
160163
unsubscribeEvent(filter.getRegisterID(), callback);
161-
}
164+
}*/
162165
}
163166

164167
private void resendWaitingFilters() {

0 commit comments

Comments
 (0)