public InMemoryChatRoomService(Flux<Message> messageFlux)
{
- log.debug("Creating InMemoryChatroomService");
+ log.debug("Creating InMemoryChatRoomService");
messages = new LinkedHashMap<>();
messageFlux.subscribe(message -> messages.put(message.getKey(), message));
}