func LoadMessage(rawdata []byte) *Message {
	m := &Message{
		flag: ControlFlag(rawdata[len(rawdata)-1]),
		data: rawdata[0 : len(rawdata)-1],
	}
	return m
}
LoadMessage load from typed channels or queues
package util
import (
	"io"
	"log"
)
type Message struct {
	flag ControlFlag
	data []byte
}
func NewMessage(flag ControlFlag, data []byte) *Message {
	m := &Message{flag: flag, data: data}
	return m
}