Skip to content

Commit 7f8f104

Browse files
authored
feat: add payload to MessageLog (#10)
1 parent 6a40eca commit 7f8f104

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

src/main/java/com/backbase/mockchannel/MessageLog.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package com.backbase.mockchannel;
22

33
import java.time.Instant;
4+
import java.util.Map;
45
import lombok.AllArgsConstructor;
56
import lombok.Data;
67

@@ -14,4 +15,5 @@ public class MessageLog {
1415
private int priority;
1516
private Instant dateSent;
1617
private Instant dateDelivered;
18+
private Map<String, Object> payload;
1719
}

src/main/java/com/backbase/mockchannel/MockConsumer.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,8 @@ public void accept(Message<Map<String,Object>> msg) {
2424
(String) msg.getHeaders().get("msgChannel"),
2525
msg.getHeaders().get("msgPriority", Integer.class),
2626
Optional.ofNullable(msg.getHeaders().getTimestamp()).map(Instant::ofEpochMilli).orElse(null),
27-
Instant.now()
27+
Instant.now(),
28+
msg.getPayload()
2829
);
2930
log.info("Message Received: {}", messageLog);
3031
this.template.convertAndSend("/topic/message-log", messageLog);

0 commit comments

Comments
 (0)