This commit is contained in:
laodaming 2023-08-10 18:12:07 +08:00
parent f8df7b55b3
commit 0c4f33b486

View File

@ -99,10 +99,10 @@ func (w *wsConnectItem) renderImage(data []byte) {
d, _ := json.Marshal(tmpData) d, _ := json.Marshal(tmpData)
//发送给对应的流水线组装数据 //发送给对应的流水线组装数据
if err := w.rabbitMq.SendMsg(constants.RABBIT_MQ_ASSEMBLE_RENDER_DATA, d); err != nil { if err := w.rabbitMq.SendMsg(constants.RABBIT_MQ_ASSEMBLE_RENDER_DATA, d); err != nil {
logx.Error("发送渲染任务数据到MQ失败:", string(data), "err:", err) logx.Error("发送渲染任务数据到MQ失败:", string(d), "err:", err)
return return
} }
logx.Info("发送渲染数据到rabbitmq成功:", string(data)) logx.Info("发送渲染数据到rabbitmq成功:", string(d))
} }
// 操作连接中渲染任务的增加/删除 // 操作连接中渲染任务的增加/删除