projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 4d03183) | 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>
Sat, 16 Mar 2024 09:10:54 +0000 (10:10 +0100)
commit465e722c9cd504932bc544c0f66e0b54007bdcdf
treeabcd9e9ff845fb46db6f36015ba7804c1f2c4ad8tree | snapshot
parent4d0318357917a17c578e6232f70f29b5fcda68c8commit | 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.