You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vi...@apache.org on 2016/12/28 08:52:41 UTC
[3/4] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: refactor ProducerApp
ASF JIRA: https://issues.apache.org/jira/browse/ROCKETMQ-17
[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 <vi...@apache.org>
Authored: Wed Dec 28 16:22:25 2016 +0800
Committer: vintagewang <vi...@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");
}