projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 0dd3090) | patch
refactor: Refined channel-states, introduced `ChannelState` -- ALIGN
authorKai Moritz <kai@juplo.de>
Mon, 4 Mar 2024 13:34:34 +0000 (14:34 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 22 Mar 2024 16:39:20 +0000 (17:39 +0100)
commit0d14c8efe97dd418aa2556916b8a7c47ea8b08b7
tree0ac0c9cae670a0a461955d37d65d82e9da46b7b7tree | snapshot
parent0dd30902befcc88b674da8d040e035aaf3a6448fcommit | diff
refactor: Refined channel-states, introduced `ChannelState` -- ALIGN

* Renamed attributes and method-names according to the class-renames.
* Introduced interface `Channel` and `enum ChannelState`.
* `Data` - and `InfoChannel` maintain a `ChannelState`, instead just a
  plain boolean, that only reflects the loading-state.
* The `ChannelTaskRunner` waits, until both channels entered the State
  `ChannelState.SHUTTING_DOWN`.
14 files changed:
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/Channel.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelNotReadyException.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelState.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelTaskExecutor.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelTaskRunner.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/InfoChannel.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesApplicationRunner.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java diff | blob | history
src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java diff | blob | history
src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeServiceTest.java diff | blob | history
src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeServiceWithShardsTest.java diff | blob | history
src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java diff | blob | history
src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.