+ }
+
+
+ Mono<Void> restore(StorageStrategy storageStrategy)
+ {
+ Flux<Message> messageFlux = storageStrategy.readChatRoomData(chatRoomId);
+
+ return messageFlux
+ .doOnNext(message -> messages.put(message.getKey(), message))
+ .then()
+ .doOnSuccess(empty -> log.info("Restored InMemoryChatMessageService"))
+ .doOnError(throwable -> log.error("Could not restore InMemoryChatMessageService"));