package consumer import "fmt" // 消费渲染需要组装的数据 type MqConsumerRenderAssemble struct { } func (m *MqConsumerRenderAssemble) Run(data []byte) error { fmt.Println("收到消息:" + string(data)) return nil }