]> juplo.de Git - demos/kafka/chat/commit
projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 1109648) | 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>
Thu, 14 Mar 2024 08:11:21 +0000 (09:11 +0100)
commit31a32e75e4f1e4513a14f048325c0a5b52f08519
tree213423ada2d1079c85c9390c080d57d2234b547dtree | snapshot
parent1109648f07788d9c6400f165cb54c83c246ea3eecommit | 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.