bla

dancier · Jan 21, 2024 · 5184207 · 5184207
1 parent 5eb208d
commit 5184207
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/main/java/net/dancier/kikeriki/adapter/in/kafka/ListenerAll.java b/src/main/java/net/dancier/kikeriki/adapter/in/kafka/ListenerAll.java
@@ -46,6 +46,7 @@ void listener(CloudEvent cloudEvent) throws IOException {
  private void messageReadEvent(CloudEvent cloudEvent) throws IOException {
  log.info("Making application event....");
  MessageReadEventDto messageReadEventDto = objectMapper.readValue(cloudEvent.getData().toBytes(), MessageReadEventDto.class);
+ log.info("Got this: {}", messageReadEventDto);
  MessageReadEvent messageReadEvent = new MessageReadEvent();
  messageReadEvent.setMessageId(messageReadEventDto.messageId);
  messageReadEvent.setReaderId(messageReadEventDto.readerId);

diff --git a/src/main/java/net/dancier/kikeriki/adapter/in/kafka/MessageReadEventDto.java b/src/main/java/net/dancier/kikeriki/adapter/in/kafka/MessageReadEventDto.java
@@ -1,5 +1,8 @@
 package net.dancier.kikeriki.adapter.in.kafka;
 
+import lombok.Data;
+
+@Data
 public class MessageReadEventDto {
 
  boolean read;