projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: fd4ec34) | patch
refactor: Introduced `ConsumerTaskExecutor` -- Aligned code
authorKai Moritz <kai@juplo.de>
Thu, 14 Sep 2023 21:42:59 +0000 (23:42 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 27 Jan 2024 14:16:22 +0000 (15:16 +0100)
commit46ba1885fe43ef5f0f9b845f22cd61d707df94cc
tree4bc73e272f4bc9297d65dda065a42db65e593b27tree | snapshot
parentfd4ec34a1ec3ebc1c6a1e34abb2124c3b97f224dcommit | diff
refactor: Introduced `ConsumerTaskExecutor` -- Aligned code

* Moved startup-logic in a separate class (`ConsumerTaskExecutor`), so
  that it is reusable more easily in test scenarios.
* `KafkaServicesApplicationRunner` is instanciated via `@Component`, so
  that it is _not_ instanciated automatically, if the configuration is
  triggered explicitly via `KafkaServicesConfiguration` in test scenarios.
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskExecutor.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/implementation/kafka/KafkaChatHomeServiceTest.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.