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 07:57:42 UTC
[4/5] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: refactor ProducerApp
class https://issues.apache.org/jira/browse/ROCKETMQ-17
[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: refactor ProducerApp class
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/9f232be5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/9f232be5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/9f232be5
Branch: refs/heads/spec
Commit: 9f232be56dcd32df0176508782264c65c5da6fff
Parents: a696404
Author: vintagewang <vi...@apache.org>
Authored: Wed Dec 28 14:55:01 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Wed Dec 28 14:55:01 2016 +0800
----------------------------------------------------------------------
.../org/apache/openmessaging/samples/ProducerApp.java | 12 ++++++++++--
1 file changed, 10 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/9f232be5/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 0182058..f820f3f 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
@@ -33,8 +33,6 @@ public class ProducerApp {
producer.start();
- producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))));
-
Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
@Override
public void run() {
@@ -42,5 +40,15 @@ public class ProducerApp {
messagingEndPoint.shutdown();
}
}));
+
+ producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))));
+ System.out.println("send first message OK");
+
+ producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))
+ .putProperty("KEY1", "value1")//
+ .putProperty("KEY2", "value2")//
+ .putProperty("KEY3", "value3")//
+ );
+ System.out.println("send second message OK");
}
}
\ No newline at end of file