This commit is contained in:
laodaming 2023-08-07 13:20:18 +08:00
parent 48e1093469
commit 956b18a72e

View File

@ -1,12 +1,14 @@
package consumer
import "fmt"
import (
"github.com/zeromicro/go-zero/core/logx"
)
// 消费渲染需要组装的数据
type MqConsumerRenderAssemble struct {
}
func (m *MqConsumerRenderAssemble) Run(data []byte) error {
fmt.Println("收到需要组装的消息:" + string(data))
logx.Info("收到需要组装的消息:", string(data))
return nil
}