[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: refactor ProducerApp ASF JIRA: https://issues.apache.org/jira/browse/ROCKETMQ-17
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/3eef3cd3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/3eef3cd3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/3eef3cd3 Branch: refs/heads/spec Commit: 3eef3cd352c9080e7f45eb14844011b92501d658 Parents: 8e98df0 Author: vintagewang <vintagew...@apache.org> Authored: Wed Dec 28 16:22:25 2016 +0800 Committer: vintagewang <vintagew...@apache.org> Committed: Wed Dec 28 16:22:25 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/openmessaging/samples/ProducerApp.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3eef3cd3/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java index 051fc22..630d372 100644 --- a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java +++ b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java @@ -47,9 +47,10 @@ public class ProducerApp { System.out.println("send first message OK"); producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))) - .putProperties("KEY1", "value1")// - .putProperties("KEY2", "value2")// - .putProperties("KEY3", "value3")// + .putProperties("KEY1", 100)// + .putProperties("KEY2", 200L)// + .putProperties("KEY3", 3.14)// + .putProperties("KEY4", "value4")// ); System.out.println("send second message OK"); }
