打印rabbitmq日志

This commit is contained in:
sk 2024-07-03 14:47:07 +08:00
parent 8117f1af54
commit 1f8b7e1d70
2 changed files with 4 additions and 1 deletions

2
public

@ -1 +1 @@
Subproject commit 63eadb869736b9d3e16c993cd99675c0e0de638c Subproject commit 3f6ae474769f33050525f59aed42321b93a788cc

View File

@ -3,6 +3,8 @@ package main
import ( import (
"reflect" "reflect"
"mongo.games.com/goserver/core/logger"
"mongo.games.com/game/model" "mongo.games.com/game/model"
"mongo.games.com/game/mq" "mongo.games.com/game/mq"
) )
@ -39,6 +41,7 @@ func (c *LogChannel) WriteLog(log interface{}) {
if cname == "" { if cname == "" {
cname = "_null_" cname = "_null_"
} }
logger.Logger.Tracef("==> RabbitMQ(%v): %#v", cname, log)
mq.Send(cname, log) mq.Send(cname, log)
} }