software/glogcenter
1
0
Fork 0
mirror of https://github.com/gotoeasy/glogcenter.git synced 2025-09-15 12:58:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

RabbitMQ

Browse Source
This commit is contained in:
gotoeasy 2022-07-05 13:11:18 +08:00
parent c5c8471f2f
commit 8b75ce34f9
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
glc/rabbitmq/consume/amqp_log_handle.go
View File

@ -4,6 +4,7 @@
package consume package consume
import ( import (
"glc/conf"
"glc/ldb" "glc/ldb"
"glc/ldb/storage/logdata" "glc/ldb/storage/logdata"
"glc/onexit" "glc/onexit"
@ -61,7 +62,11 @@ func fnAmqpJsonLogHandle(jsonLog string, err error) bool {
log.Println("接收到rabbitmq的日志", jsonLog) log.Println("接收到rabbitmq的日志", jsonLog)
md := &logdata.LogDataModel{} md := &logdata.LogDataModel{}
md.LoadJson(jsonLog) if conf.IsAmqpJsonFormat() {
md.LoadJson(jsonLog)
} else {
md.Text = jsonLog
}
engine := ldb.NewDefaultEngine() engine := ldb.NewDefaultEngine()
engine.AddTextLog(md.Date, md.Text, md.System) engine.AddTextLog(md.Date, md.Text, md.System)