Merge pull request #67 from duhenglucky/metadata

[ISSUE #68]Export offset and partition meta data

Author: duhenglucky

openmessaging-api/src/main/java/io/openmessaging/api/Message.java

@@ -237,6 +237,28 @@ public void setStartDeliverTime(final long value) {
         putSystemProperties(SystemPropKey.STARTDELIVERTIME, String.valueOf(value));
     }
 
+    /**
+     * Get the offset of this message assigned by the broker.
+     *
+     * @return Message offset in relative partition
+     */
+    public long getOffset() {
+        String v = getSystemProperties(SystemPropKey.CONSUMEOFFSET);
+        if (v != null) {
+            return Long.parseLong(v);
+        }
+        return 0;
+    }
+
+    /**
+     * Get the partition to which the message belongs.
+     *
+     * @return Message offset in relative partition
+     */
+    public TopicPartition getTopicPartition() {
+        return new TopicPartition(topic, getSystemProperties(SystemPropKey.PARTITION));
+    }
+
     @Override
     public String toString() {
         return "Message [topic=" + topic + ", systemProperties=" + systemProperties + ", userProperties=" + userProperties + ", body="
@@ -253,5 +275,9 @@ static public class SystemPropKey {
         public static final String BORNHOST = "__BORNHOST";
 
         public static final String STARTDELIVERTIME = "__STARTDELIVERTIME";
+
+        public static final String CONSUMEOFFSET = "__CONSUMEOFFSET";
+
+        public static final String PARTITION = "__PARTITION";
     }
 }