[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 <[email protected]> Authored: Wed Dec 28 14:55:01 2016 +0800 Committer: vintagewang <[email protected]> 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
