Function LoadMessage

util/read_write.go:22–28

LoadMessage load from typed channels or queues

(rawdata []byte)

// LoadMessage load from typed channels or queues
func LoadMessage(rawdata []byte) *Message {
	m := &Message{
		flag: ControlFlag(rawdata[len(rawdata)-1]),
		data: rawdata[0 : len(rawdata)-1],
	}
	return m
}

func (m *Message) Flag() ControlFlag {
	return m.flag