for (int shard = 0; shard < chatHomes.length; shard++)
if(chatHomes[shard] != null)
this.ownedShards.add(shard);
- log.info(
- "Created ShardedChatHome for shards: {}",
- ownedShards
- .stream()
- .map(String::valueOf)
- .collect(Collectors.joining(", ")));
+ log.info("Created {}", this);
}
{
return shardingStrategy.selectShard(chatroomId);
}
+
+ @Override
+ public String toString()
+ {
+ StringBuffer stringBuffer = new StringBuffer(ShardedChatHomeService.class.getSimpleName());
+ stringBuffer.append(", shards=[");
+ stringBuffer.append(ownedShards
+ .stream()
+ .sorted()
+ .map(String::valueOf)
+ .collect(Collectors.joining(",")));
+ stringBuffer.append("]");
+ return stringBuffer.toString();
+ }
}