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/25 13:17:48 UTC
incubator-rocketmq git commit: Develop a vendor-neutral open standard
for distributed messaging: implement message class
Repository: incubator-rocketmq
Updated Branches:
refs/heads/spec a00a6e28a -> 90ba64810
Develop a vendor-neutral open standard for distributed messaging: implement message class
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/90ba6481
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/90ba6481
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/90ba6481
Branch: refs/heads/spec
Commit: 90ba64810299b8c30aeacc59ba599eca8ee47ae1
Parents: a00a6e2
Author: vintagewang <vi...@apache.org>
Authored: Sun Dec 25 21:13:33 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Sun Dec 25 21:13:33 2016 +0800
----------------------------------------------------------------------
.../java/org/apache/openmessaging/Message.java | 29 ++++++++++++++++++++
1 file changed, 29 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/90ba6481/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java
----------------------------------------------------------------------
diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java
index 67e2326..e89b8af 100644
--- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java
+++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java
@@ -17,8 +17,37 @@
package org.apache.openmessaging;
+import java.util.Map;
+
/**
* @author vintagewang@apache.org
*/
public class Message {
+ private Map<String, String> header;
+ private Map<String, String> properties;
+ private byte[] body;
+
+ public Map<String, String> getHeader() {
+ return header;
+ }
+
+ public void setHeader(final Map<String, String> header) {
+ this.header = header;
+ }
+
+ public Map<String, String> getProperties() {
+ return properties;
+ }
+
+ public void setProperties(final Map<String, String> properties) {
+ this.properties = properties;
+ }
+
+ public byte[] getBody() {
+ return body;
+ }
+
+ public void setBody(final byte[] body) {
+ this.body = body;
+ }
}
\ No newline at end of file