[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: refactor producer 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/159804d9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/159804d9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/159804d9 Branch: refs/heads/spec Commit: 159804d9123b780e7a3aaf019127f460b0e88b18 Parents: 602dafc Author: vintagewang <[email protected]> Authored: Sun Jan 1 21:14:20 2017 +0800 Committer: vintagewang <[email protected]> Committed: Sun Jan 1 21:14:20 2017 +0800 ---------------------------------------------------------------------- .../java/src/main/java/org/apache/openmessaging/KeyValue.java | 4 ++++ .../java/src/main/java/org/apache/openmessaging/Producer.java | 6 ++++++ 2 files changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/159804d9/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java index b75c424..7caebd6 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java @@ -16,6 +16,8 @@ */ package org.apache.openmessaging; +import java.util.Set; + public interface KeyValue { KeyValue put(final String key, final int value); @@ -32,4 +34,6 @@ public interface KeyValue { double getDouble(final String key); String getString(final String key); + + Set<String> keySet(); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/159804d9/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java index 53c2194..d8889d0 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java @@ -23,7 +23,13 @@ public interface Producer extends MessageFactory { void send(final BytesMessage message); + void send(final BytesMessage message, final KeyValue properties); + Promise<Void> sendAsync(final BytesMessage message); + Promise<Void> sendAsync(final BytesMessage message, final KeyValue properties); + void sendOneway(final BytesMessage message); + + void sendOneway(final BytesMessage message, final KeyValue properties); } \ No newline at end of file
