projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 6e9b68d) | patch
fix: GREEN - `ChatRoomData` obeys to the added expectations.
authorKai Moritz <kai@juplo.de>
Sat, 9 Mar 2024 10:17:33 +0000 (11:17 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 22 Mar 2024 16:39:20 +0000 (17:39 +0100)
commit9a3898831e031353da657533e2f14cf8925036a3
treee9683fbc058bf60a4a683cfaf5ac12d17fe00f24tree | snapshot
parent6e9b68d07e0f48a6f7b4f97697ce461e51eb48a6commit | diff
fix: GREEN - `ChatRoomData` obeys to the added expectations.

* Switched `ChatRoomData` from a multicast- to a replay-sink.
* Before, listening was implemented with a multicast-sink, that enabled
  back-pressure.
* Now, it was refactored to use a replay-sink, that enables a (configurable)
  limitted replay.
src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomData.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/inmemory/InMemoryServicesConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/inmemory/SimpleChatHomeService.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.