String text)
{
return chatMessageChannel
- .sendMessage(chatRoomId, key, timestamp, text)
+ .sendChatMessage(chatRoomId, key, timestamp, text)
.doOnSuccess(message -> persistMessage(message));
}
- public void persistMessage(Message message)
+ void persistMessage(Message message)
{
messages.put(message.getKey(), message);
}