Repository: activemq-artemis Updated Branches: refs/heads/master 973c51921 -> 5316a8048
ARTEMIS-1009 Fixing example Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/b851a59e Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/b851a59e Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/b851a59e Branch: refs/heads/master Commit: b851a59ec58daa883ed8ed1a92722de5746c5860 Parents: 94b47e3 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Mon Mar 6 17:39:57 2017 -0500 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Mon Mar 6 22:09:41 2017 -0500 ---------------------------------------------------------------------- .../artemis/jms/example/AddForwardingTimeTransformer.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b851a59e/examples/features/standard/divert/src/main/java/org/apache/activemq/artemis/jms/example/AddForwardingTimeTransformer.java ---------------------------------------------------------------------- diff --git a/examples/features/standard/divert/src/main/java/org/apache/activemq/artemis/jms/example/AddForwardingTimeTransformer.java b/examples/features/standard/divert/src/main/java/org/apache/activemq/artemis/jms/example/AddForwardingTimeTransformer.java index 2f75d4c..37fe747 100644 --- a/examples/features/standard/divert/src/main/java/org/apache/activemq/artemis/jms/example/AddForwardingTimeTransformer.java +++ b/examples/features/standard/divert/src/main/java/org/apache/activemq/artemis/jms/example/AddForwardingTimeTransformer.java @@ -17,12 +17,15 @@ package org.apache.activemq.artemis.jms.example; import org.apache.activemq.artemis.api.core.Message; +import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.core.server.cluster.Transformer; public class AddForwardingTimeTransformer implements Transformer { @Override public Message transform(final Message message) { + message.putLongProperty(new SimpleString("time_of_forward"), System.currentTimeMillis()); + return message; }
