activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/3] activemq-artemis git commit: ARTEMIS-1009 Fixing example
Date Tue, 07 Mar 2017 03:12:35 GMT
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 <clebertsuconic@apache.org>
Authored: Mon Mar 6 17:39:57 2017 -0500
Committer: Clebert Suconic <clebertsuconic@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;
    }
 


Mime
View raw message