:gear: Add marshalling accessor to Message

pkg/hub/message.go

@@ -15,6 +15,8 @@
 
 package hub
 
+import "encoding/json"
+
 // Message gets converted to/from JSON and sent in the body of pubsub messages.
 type Message struct {
 	Message  string
@@ -53,3 +55,11 @@ func (m *Message) WithMessage(s string) *Message {
 	copy.Message = s
 	return copy
 }
+
+func (m *Message) AnnotationsToObj(v interface{}) error {
+	blob, err := json.Marshal(m.Annotations)
+	if err != nil {
+		return err
+	}
+	return json.Unmarshal(blob, v)
+}