-
- Mono.error(() -> new MessageMutationException(existing, text)));
- Message message = new Message(key, (long)messages.size(), timestamp, text);
+ return chatMessageChannel
+ .sendMessage(chatRoomId, key, timestamp, text)
+ .doOnSuccess(message -> persistMessage(message));
+ }
+
+ void persistMessage(Message message)
+ {