projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: b3604ee) | patch
refactor: Refined channel-states, introduced `ChannelState` -- MOVE
authorKai Moritz <kai@juplo.de>
Mon, 4 Mar 2024 13:32:14 +0000 (14:32 +0100)
committerKai Moritz <kai@juplo.de>
Thu, 14 Mar 2024 08:11:21 +0000 (09:11 +0100)
commiteaec0e92a1887c6b1c0059de1b5db44039dc1dd4
tree9fcba367d34a42c9b9bf6660e9c1e5e9a1a5f371tree | snapshot
parentb3604ee493ab20909fa63486a9abbc2c252abac8commit | diff
refactor: Refined channel-states, introduced `ChannelState` -- MOVE

* Renamed and moved `LoadInProgressException`
** Moved exception into implementation-specific package
** Renamed exception to `ChannelNotReadyException`
* Renamed `ConsumerTaskExecutor` into `ChannelTaskExecutor`
* Renamed `ConsumerTaskRunner` into `ChannelTaskRunner`
src/main/java/de/juplo/kafka/chat/backend/domain/exceptions/LoadInProgressException.java [deleted file] blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelNotReadyException.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelTaskExecutor.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelTaskRunner.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskExecutor.java [deleted file] blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java [deleted file] blob | history
Unnamed repository; edit this file 'description' to name the repository.