Clock clock,
int bufferSize)
{
- log.info("Created SimpleChatHome for shard {}", shard);
;
this.shard = shard;
+ log.info("Created {}", this);
+
this.chatRoomInfo = new HashMap<>();
this.chatRoomData = new HashMap<>();
storageStrategy
.justOrEmpty(chatRoomData.get(id))
.switchIfEmpty(Mono.error(() -> new UnknownChatroomException(id)));
}
+
+ @Override
+ public Mono<String[]> getShardOwners()
+ {
+ return Mono.empty();
+ }
+
+ @Override
+ public String toString()
+ {
+ return SimpleChatHomeService.class.getSimpleName() + ", shard=" + shard;
+ }
}