diff --git a/src/main/java/com/backbase/mockchannel/MessageLog.java b/src/main/java/com/backbase/mockchannel/MessageLog.java index 994329c..c6dc2fd 100644 --- a/src/main/java/com/backbase/mockchannel/MessageLog.java +++ b/src/main/java/com/backbase/mockchannel/MessageLog.java @@ -9,6 +9,7 @@ public class MessageLog { private String tag; + private String trackingId; private String channel; private int priority; private Instant dateSent; diff --git a/src/main/java/com/backbase/mockchannel/MockConsumer.java b/src/main/java/com/backbase/mockchannel/MockConsumer.java index 7af54ec..b170216 100644 --- a/src/main/java/com/backbase/mockchannel/MockConsumer.java +++ b/src/main/java/com/backbase/mockchannel/MockConsumer.java @@ -20,6 +20,7 @@ public class MockConsumer implements Consumer>> { public void accept(Message> msg) { MessageLog messageLog = new MessageLog( (String) msg.getHeaders().get("msgTag"), + (String) msg.getHeaders().get("trackingId"), (String) msg.getHeaders().get("msgChannel"), msg.getHeaders().get("msgPriority", Integer.class), Optional.ofNullable(msg.getHeaders().getTimestamp()).map(Instant::ofEpochMilli).orElse(null),