Repository: incubator-rocketmq Updated Branches: refs/heads/spec f3d7a1e61 -> 89945900c
[ROCKETMQ-17] openmessaging: support topic & queue 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/89945900 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/89945900 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/89945900 Branch: refs/heads/spec Commit: 89945900cd77f5b5de1c312ddea1987ee480b39e Parents: f3d7a1e Author: vintagewang <[email protected]> Authored: Sat Jan 7 22:38:37 2017 +0800 Committer: vintagewang <[email protected]> Committed: Sat Jan 7 22:38:37 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/openmessaging/MessageFactory.java | 4 +++- .../java/org/apache/openmessaging/MessageHeader.java | 2 ++ .../apache/openmessaging/samples/async/ProducerApp.java | 6 +++--- .../apache/openmessaging/samples/simple/ProducerApp.java | 11 +++++++---- 4 files changed, 15 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/89945900/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java index fa508e5..488dd65 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java @@ -17,5 +17,7 @@ package org.apache.openmessaging; public interface MessageFactory { - BytesMessage createBytesMessage(final String topic, final byte[] body); + BytesMessage createBytesMessageToTopic(final String topic, final byte[] body); + + BytesMessage createBytesMessageToQueue(final String queue, final byte[] body); } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/89945900/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java index 13cfe4e..fa23a45 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java @@ -18,7 +18,9 @@ package org.apache.openmessaging; public class MessageHeader { public static final String MessageId = "MessageId"; + public static final String Destination = "Destination"; public static final String Topic = "Topic"; + public static final String Queue = "Queue"; public static final String BornTimestamp = "BornTimestamp"; public static final String BornHost = "BornHost"; public static final String StoreTimestamp = "StoreTimestamp"; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/89945900/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/async/ProducerApp.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/async/ProducerApp.java b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/async/ProducerApp.java index 7c519cd..dd888f7 100644 --- a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/async/ProducerApp.java +++ b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/async/ProducerApp.java @@ -44,13 +44,13 @@ public class ProducerApp { })); { - final Promise<Void> result = producer.sendAsync(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))); + final Promise<Void> result = producer.sendAsync(producer.createBytesMessageToTopic("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))); final Void aVoid = result.get(3000L); System.out.println("send async message OK"); } { - final Promise<Void> result = producer.sendAsync(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))); + final Promise<Void> result = producer.sendAsync(producer.createBytesMessageToTopic("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))); result.addListener(new PromiseListener<Void>() { @Override public void operationComplete(Promise<Void> promise) { System.out.println("send async message OK"); @@ -65,7 +65,7 @@ public class ProducerApp { } { - producer.sendOneway(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))); + producer.sendOneway(producer.createBytesMessageToTopic("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))); System.out.println("send oneway message OK"); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/89945900/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/simple/ProducerApp.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/simple/ProducerApp.java b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/simple/ProducerApp.java index 4460345..e14d6e0 100644 --- a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/simple/ProducerApp.java +++ b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/simple/ProducerApp.java @@ -42,15 +42,18 @@ public class ProducerApp { } })); - producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))); - System.out.println("send first message OK"); + producer.send(producer.createBytesMessageToTopic("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))); + System.out.println("send first message to topic OK"); - producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))) + producer.send(producer.createBytesMessageToTopic("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))) .putProperties("KEY1", 100)// .putProperties("KEY2", 200L)// .putProperties("KEY3", 3.14)// .putProperties("KEY4", "value4")// ); - System.out.println("send second message OK"); + System.out.println("send second message to topic OK"); + + producer.send(producer.createBytesMessageToQueue("HELLO_QUEUE", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))); + System.out.println("send third message to queue OK"); } } \ No newline at end of file
