Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-1009 Fixing example

This commit is contained in:
Clebert Suconic 2017-03-06 17:39:57 -05:00
parent 94b47e370b
commit b851a59ec5
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/features/standard/divert/src/main/java/org/apache/activemq/artemis/jms/example/AddForwardingTimeTransformer.java
View File

@ -17,12 +17,15 @@
package org.apache.activemq.artemis.jms.example; package org.apache.activemq.artemis.jms.example;
import org.apache.activemq.artemis.api.core.Message; 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; import org.apache.activemq.artemis.core.server.cluster.Transformer;
public class AddForwardingTimeTransformer implements Transformer { public class AddForwardingTimeTransformer implements Transformer {
@Override @Override
public Message transform(final Message message) { public Message transform(final Message message) {
message.putLongProperty(new SimpleString("time_of_forward"), System.currentTimeMillis());
return message; return message;
} }