+ default void writeChatRoomData(UUID chatRoomId, Flux<Message> messageFlux)
+ {
+ writeChatRoomData(
+ chatRoomId,
+ messageFlux,
+ (id) -> log.info("Successfully stored chat-room {}", id),
+ (id, throwable) -> log.error("Could not store chat-room {}: {}", id, throwable));
+ }
+