[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: refactor BytesMessage 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/8e98df0d Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/8e98df0d Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/8e98df0d Branch: refs/heads/spec Commit: 8e98df0d759a3f18e6f625914d5f683e9cbd49c8 Parents: 70253cd Author: vintagewang <vintagew...@apache.org> Authored: Wed Dec 28 16:14:50 2016 +0800 Committer: vintagewang <vintagew...@apache.org> Committed: Wed Dec 28 16:14:50 2016 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/openmessaging/BytesMessage.java | 4 ++++ .../java/src/main/java/org/apache/openmessaging/KeyValue.java | 4 ++++ 2 files changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8e98df0d/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java index 629cca2..9d882cc 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java @@ -22,12 +22,16 @@ public interface BytesMessage extends Message { BytesMessage putHeader(final String key, final long value); + BytesMessage putHeader(final String key, final double value); + BytesMessage putHeader(final String key, final String value); BytesMessage putProperties(final String key, final int value); BytesMessage putProperties(final String key, final long value); + BytesMessage putProperties(final String key, final double value); + BytesMessage putProperties(final String key, final String value); byte[] getBody(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8e98df0d/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 c3f44f5..87acf57 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 @@ -22,11 +22,15 @@ public interface KeyValue { KeyValue put(final String key, final long value); + KeyValue put(final String key, final double value); + KeyValue put(final String key, final String value); int getInt(final String key); long getLong(final String key); + double getDouble(final String key); + String getString(final String key); }
