projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 0ff0e01) | patch
feat: first runnable implementation, that is based on Kafka
authorKai Moritz <kai@juplo.de>
Sun, 22 Jan 2023 17:13:40 +0000 (18:13 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 26 Jan 2024 18:08:55 +0000 (19:08 +0100)
commite7af512057440075a779ff5a5401dd11fc962741
treee3be7af55176bc2de84e04b80d1e3c46e6495657tree | snapshot
parent0ff0e013a3d1f112f8e8c7280a4948ce0662eb10commit | diff
feat: first runnable implementation, that is based on Kafka
18 files changed:
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoom.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomFactory.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/InMemoryChatRoomFactory.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomChannel.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHome.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatRoomFactory.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatRoomService.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesApplicationRunner.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/LoadInProgressException.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/messages/AbstractMessageTo.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/messages/CommandCreateChatRoomTo.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/messages/EventChatMessageReceivedTo.java [new file with mode: 0644] blob
src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java [new file with mode: 0644] blob
src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/messages/CommandCreateChatRoomToTest.java [new file with mode: 0644] blob
src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/messages/EventChatMessageReceivedToTest.java [new file with mode: 0644] blob
Unnamed repository; edit this file 'description' to name the repository.