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>
	Tue, 20 Feb 2024 09:35:33 +0000 (10:35 +0100)
commit	ed2aafc2cbb762a212d3be895fbebd84656e4da1
tree	ae5ac793dac866a25e2c82453b137364d7f98198	tree \| snapshot
parent	58522d1ddff4795d9c924d90cd1695d6c8d30a38	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