X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FChatRoom.java;h=cc5c5a07d2503732d09483bc1b69525e6d8b43e9;hb=daca33d027e4c0d036fc2aa7c3d9b2120f3ad98a;hp=4496585232c0ea71cdba3fc5c1be5ab6277bd88b;hpb=9d61871563f4be4850cebca4fad0545d504522c3;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoom.java b/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoom.java index 44965852..cc5c5a07 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoom.java +++ b/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoom.java @@ -25,8 +25,6 @@ public class ChatRoom private final UUID id; @Getter private final String name; - @Getter - private final int shard; private final Clock clock; private final ChatRoomService service; private final int bufferSize; @@ -36,14 +34,13 @@ public class ChatRoom public ChatRoom( UUID id, String name, - int shard, Clock clock, ChatRoomService service, int bufferSize) { + log.info("Created ChatRoom {} with buffer-size {}", id, bufferSize); this.id = id; this.name = name; - this.shard = shard; this.clock = clock; this.service = service; this.bufferSize = bufferSize;