diff --git a/log/mq/nsq.go b/log/mq/nsq.go index 6e9be64..39339f0 100644 --- a/log/mq/nsq.go +++ b/log/mq/nsq.go @@ -79,13 +79,15 @@ func (l *nsqLogger) Log(level log.Level, keyvals ...any) error { if len(keyvals)&1 == 1 { keyvals = append(keyvals, "KEYVALS UNPAIRED") } - buf := make(map[any]any) + buf := make(map[string]any) buf["status"] = level.String() for i := 0; i < len(keyvals); i += 2 { - buf[keyvals[i]] = keyvals[i+1] + buf[fmt.Sprintf("%v", keyvals[i])] = keyvals[i+1] + } + body, err := json.Marshal(buf) + if err != nil { + return err } - body, _ := json.Marshal(buf) - fmt.Println("ww", string(body)) l.list <- body return nil } diff --git a/log/mq/nsq_test.go b/log/mq/nsq_test.go new file mode 100644 index 0000000..78a795b --- /dev/null +++ b/log/mq/nsq_test.go @@ -0,0 +1,14 @@ +package mq + +import ( + "git.diulo.com/mogfee/protoc-gen-kit/log" + "testing" +) + +func Test_nsqLogger_Log(t *testing.T) { + logger := log.With(NewNsqLogger("localhost:4150", "app_log"), + "ts", log.DefaultTimestamp, + "caller", log.DefaultCaller, + ) + logger.Log(log.LevelInfo, "user name ttt") +}