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

Kai Moritz [Sun, 25 Dec 2022 22:02:47 +0000 (23:02 +0100)]

feat: Implemented an endpoint to get the details of a chatroom

Kai Moritz [Wed, 21 Dec 2022 17:57:23 +0000 (18:57 +0100)]

feat: implemented a listen-method for the chat-service based on a Flux

- Switched the return-type of `Chatroom.addMessage()` to `Mono<Message>`.
- Added an inner method, that "persists" the message and also returns
  `Mono<Message>`.
- `addMessage()` calls `persistMessage()`, peeks into the subscription and
  emits the `Message` to an internal `Sink.multy()` of the `Chatroom`.
- `Chatroom.listen()` creates a `Flux` from the internal Sink, so that
  multiple subscribers can listen on the sink and all retrieve the current
  messages in parallel.

commit | commitdiff | tree

Kai Moritz [Tue, 20 Dec 2022 21:25:42 +0000 (22:25 +0100)]

feat: implemented a simplified chatroom-service

commit | commitdiff | tree

Kai Moritz [Tue, 20 Dec 2022 17:27:11 +0000 (18:27 +0100)]

chore: Switched configuration from *.properties to YAML

commit | commitdiff | tree

Kai Moritz [Tue, 20 Dec 2022 17:26:15 +0000 (18:26 +0100)]

refactor: Simplified the name of the application-class

commit | commitdiff | tree

Kai Moritz [Sun, 15 Jan 2023 18:31:18 +0000 (19:31 +0100)]

chore: Fixed indentation of the `pom.xml`