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 08:52:40 UTC
[2/4] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: refactor BytesMessage
ASF JIRA: https://issues.apache.org/jira/browse/ROCKETMQ-17
[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 <vi...@apache.org>
Authored: Wed Dec 28 16:14:50 2016 +0800
Committer: vintagewang <vi...@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);
}