chatRoomId,
partition,
bufferSize);
- KafkaChatRoomService service = new KafkaChatRoomService(this, chatRoomId);
+ KafkaChatMessageService service = new KafkaChatMessageService(this, chatRoomId);
ChatRoomData chatRoomData = new ChatRoomData(
clock,
service,
{
UUID id = chatRoomInfo.getId();
log.info("Creating ChatRoom {} with buffer-size {}", id, bufferSize);
- KafkaChatRoomService service = new KafkaChatRoomService(this, id);
+ KafkaChatMessageService service = new KafkaChatMessageService(this, id);
ChatRoomData chatRoomData = new ChatRoomData(clock, service, bufferSize);
putChatRoom(
chatRoomInfo.getId(),
Message message = new Message(key, offset, timestamp, chatMessageTo.getText());
ChatRoomData chatRoomData = this.chatRoomData[partition].get(chatRoomId);
- KafkaChatRoomService kafkaChatRoomService =
- (KafkaChatRoomService) chatRoomData.getChatRoomService();
+ KafkaChatMessageService kafkaChatRoomService =
+ (KafkaChatMessageService) chatRoomData.getChatRoomService();
kafkaChatRoomService.persistMessage(message);
}