- new InMemoryChatRoomService(messageFlux),
- bufferSize));
- });
- this.clock = clock;
- this.bufferSize = bufferSize;
+ chatMessageService,
+ historyLimit);
+ chatRoomData.activate();
+ this.chatRoomData.put(info.getId(), chatRoomData);
+
+ return chatMessageService.restore(storageStrategy);
+ })
+ .count()
+ .doOnSuccess(count -> log.info("Restored {} with {} chat-rooms", this, count))
+ .doOnError(throwable -> log.error("Could not restore {}", this))
+ .then();