projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 9513563) | 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>
Fri, 22 Mar 2024 16:39:20 +0000 (17:39 +0100)
commit0dd30902befcc88b674da8d040e035aaf3a6448f
treed107a8573d46235b9ce383fce3d229f989df41a1tree | snapshot
parent9513563c42a5b81361282cea9da976ed25b8f2e0commit | 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.