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 394febacd1a51e921c8012a4790883f75cb7653c Author: Claus Ibsen <[email protected]> AuthorDate: Wed Jun 9 09:35:12 2021 +0200 CAMEL-16627: camel-core - Add common header for source timestamp --- .../src/main/java/org/apache/camel/component/pubnub/PubNubConsumer.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubConsumer.java b/components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubConsumer.java index ad3e200..d8554e2 100644 --- a/components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubConsumer.java +++ b/components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubConsumer.java @@ -108,6 +108,7 @@ public class PubNubConsumer extends DefaultConsumer { inmessage.setBody(message); inmessage.setHeader(TIMETOKEN, message.getTimetoken()); inmessage.setHeader(CHANNEL, message.getChannel()); + inmessage.setHeader(Exchange.MESSAGE_TIMESTAMP, message.getTimetoken()); try { getProcessor().process(exchange); } catch (Exception e) { @@ -122,6 +123,7 @@ public class PubNubConsumer extends DefaultConsumer { inmessage.setBody(presence); inmessage.setHeader(TIMETOKEN, presence.getTimetoken()); inmessage.setHeader(CHANNEL, presence.getChannel()); + inmessage.setHeader(Exchange.MESSAGE_TIMESTAMP, presence.getTimetoken()); try { getProcessor().process(exchange); } catch (Exception e) {
