This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 1813dc395aaf6c882fad61fa89f280a9937ab36e Author: Claus Ibsen <[email protected]> AuthorDate: Wed Jun 9 09:28:19 2021 +0200 CAMEL-16627: camel-core - Add common header for source timestamp --- .../apache/camel/component/pulsar/utils/message/PulsarMessageUtils.java | 1 + 1 file changed, 1 insertion(+) diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/message/PulsarMessageUtils.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/message/PulsarMessageUtils.java index c25b1d3..ec900d1 100644 --- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/message/PulsarMessageUtils.java +++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/message/PulsarMessageUtils.java @@ -54,6 +54,7 @@ public final class PulsarMessageUtils { msg.setHeader(SEQUENCE_ID, message.getSequenceId()); msg.setHeader(PUBLISH_TIME, message.getPublishTime()); msg.setHeader(PROPERTIES, message.getProperties()); + msg.setHeader(Exchange.MESSAGE_TIMESTAMP, message.getPublishTime()); msg.setBody(message.getValue());
