juplo.de Git - demos/kafka/chat/commit

projects / demos / kafka / chat / commit

author	Kai Moritz <kai@juplo.de>
	Tue, 12 Sep 2023 21:33:59 +0000 (23:33 +0200)
committer	Kai Moritz <kai@juplo.de>
	Sat, 27 Jan 2024 14:16:23 +0000 (15:16 +0100)
commit	f3d558866e0f2a1cb002b558f3d094159a31daf5
tree	1a87269f6873f70aef086b87cab32208f319302e	tree \| snapshot
parent	6500199fa457b2c94497952ea0aaf8be6de5cdda	commit \| diff

refactor: Separated channels for data and info -- Refactored/aligned code

* Split `ChatRoomChannel` into `InfoChannel` and `DataChannel`
** `DataChannel` manages only data for chat-messages
** `InfoChannel` manages all info-data (at the moment only
`EventChatRoomCreated`)
* Aligned test-setup for kafka-related tests

18 files changed:

src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java		diff \| blob \| history
src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomInfo.java		diff \| blob \| history
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/ConsumerTaskRunner.java	[new file with mode: 0644]	blob
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java		diff \| blob \| history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java		diff \| blob \| history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeService.java		diff \| blob \| history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatMessageService.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/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/AbstractMessageTo.java		diff \| blob \| history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/EventChatMessageReceivedTo.java		diff \| blob \| history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/info/EventChatRoomCreated.java		diff \| blob \| history
src/main/java/de/juplo/kafka/chat/backend/storage/mongodb/ChatRoomTo.java		diff \| blob \| history
src/main/java/de/juplo/kafka/chat/backend/storage/mongodb/MongoDbStorageStrategy.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
src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/EventChatMessageReceivedToTest.java		diff \| blob \| history

Unnamed repository; edit this file 'description' to name the repository.

RSS Atom