Signal/Signal-Server
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Server synced 2026-04-21 06:18:06 +01:00
Code Issues Packages Projects Releases Wiki Activity

Standardize toplogy event handling strategy.

Browse Source
This commit is contained in:
Jon Chambers
2021-01-10 14:53:59 -05:00
committed by Jon Chambers
parent 22f7bb822f
commit cac86d1f77
2 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
service/src/main/java/org/whispersystems/textsecuregcm/push/ClientPresenceManager.java
View File

@@ -107,10 +107,7 @@ public class ClientPresenceManager extends RedisClusterPubSubAdapter<String, Str
connection.addListener(this);
connection.getResources().eventBus().get()
.filter(event -> event instanceof ClusterTopologyChangedEvent)
.handle((event, sink) -> {
resubscribeAll();
sink.next(event);
});
.subscribe(event -> resubscribeAll());
final String presenceChannel = getManagerPresenceChannel(managerId);
final int slot = SlotHash.getSlot(presenceChannel);

5
service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesCache.java
View File

@@ -115,10 +115,7 @@ public class MessagesCache extends RedisClusterPubSubAdapter<String, String> imp
connection.addListener(this);
connection.getResources().eventBus().get()
.filter(event -> event instanceof ClusterTopologyChangedEvent)
.handle((event, sink) -> {
resubscribeAll();
sink.next(event);
});
.subscribe(event -> resubscribeAll());
});
}