dataChannel.getOwnedShards())));
}
- int selectShard(UUID chatRoomId)
+ @Override
+ public Mono<String[]> getShardOwners()
+ {
+ return infoChannel.getShardOwners();
+ }
+
+ private int selectShard(UUID chatRoomId)
{
byte[] serializedKey = chatRoomId.toString().getBytes();
return Utils.toPositive(Utils.murmur2(serializedKey)) % numPartitions;