[#101] Added new base message function. (#102)

Added a function for NewBaseMessage()

Author: nandagopalan

messaging/base_message.go

@@ -7,6 +7,7 @@ import (
 
 	"oss.nandlabs.io/golly/codec"
 	"oss.nandlabs.io/golly/ioutils"
+	"oss.nandlabs.io/golly/uuid"
 )
 
 type BaseMessage struct {
@@ -16,6 +17,20 @@ type BaseMessage struct {
 	body        *bytes.Buffer
 }
 
+func NewBaseMessage() (baseMsg *BaseMessage, err error) {
+	var uid *uuid.UUID
+	uid, err = uuid.V4()
+	if err == nil {
+		baseMsg = &BaseMessage{
+			id:          uid.String(),
+			headers:     make(map[string]interface{}),
+			headerTypes: make(map[string]reflect.Kind),
+			body:        &bytes.Buffer{},
+		}
+	}
+	return
+}
+
 func (bm *BaseMessage) Id() string {
 	return bm.id
 }

messaging/local_message.go

@@ -1,29 +1,16 @@
 package messaging
 
-import (
-	"bytes"
-	"reflect"
-
-	"oss.nandlabs.io/golly/uuid"
-)
-
 type LocalMessage struct {
 	*BaseMessage
 }
 
 func NewLocalMessage() (msg Message, err error) {
-	var uid *uuid.UUID
-	uid, err = uuid.V4()
-	if err != nil {
-		return
-	}
-	msg = &LocalMessage{
-		BaseMessage: &BaseMessage{
-			id:          uid.String(),
-			headers:     make(map[string]interface{}),
-			headerTypes: make(map[string]reflect.Kind),
-			body:        &bytes.Buffer{},
-		},
+	var baseMsg *BaseMessage
+	baseMsg, err = NewBaseMessage()
+	if err == nil {
+		msg = &LocalMessage{
+			BaseMessage: baseMsg,
+		}
 	}
 	return
 }