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 <[email protected]> Authored: Sun Dec 25 21:13:33 2016 +0800 Committer: vintagewang <[email protected]> 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 [email protected] */ 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
