projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: eaec0e9) | 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>
Thu, 14 Mar 2024 08:11:21 +0000 (09:11 +0100)
commit5168b2e2a25b5890fe39ea5fba16688f81b3d3a2
tree057c74e71b6a46065e5e18b6d5a0e5b868e6ac92tree | snapshot
parenteaec0e92a1887c6b1c0059de1b5db44039dc1dd4commit | 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.