]> juplo.de Git - demos/kafka/chat/commit
projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 8db33e8) | patch
refactor: Simplified shutdown - channel-tasks were joined multiple times
authorKai Moritz <kai@juplo.de>
Wed, 6 Mar 2024 09:07:53 +0000 (10:07 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 22 Mar 2024 16:39:20 +0000 (17:39 +0100)
commite15fdb383ec1f34da5c08da17df8d0ee83b3369e
tree5cf8e294602f6912825898cdf8a8305fdeaab527tree | snapshot
parent8db33e8ce2f4be4146d7b7989a8ef1e40448f9e7commit | diff
refactor: Simplified shutdown - channel-tasks were joined multiple times

* `KafkaServicesApplicationRunner` does not have to join the channel-tasks.
* The channel-tasks are already joined by `ChannelTaskExecutor.join()`
  automatically, because the method is annotated with `@PreDestroy`.
* Simplified the test-configuration accordingly.
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/KafkaServicesApplicationRunner.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/implementation/kafka/KafkaChatHomeServiceTest.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.