func (p *Message) AsType(t interface{}) *Message {
	fmt.Println("[DEBUG] setting Message decoding to type:", reflect.TypeOf(t))
	p.Type = t

	return p
}
func (p *Message) AsType(t interface{}) *Message {
	fmt.Println("[DEBUG] setting Message decoding to type:", reflect.TypeOf(t))
	p.Type = t

	return p
}
// AsType specifies that the content sent through to the
// consumer handler should be sent as the given type