From 4a887b0e58dc435a4455732e44b238b470ef4cfd Mon Sep 17 00:00:00 2001
From: bandl <1658002533@qq.com>
Date: Tue, 19 Oct 2021 16:05:24 +0800
Subject: [PATCH] feat(logx): update send msg mode

---
 pkg/logx/logx.go | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git a/pkg/logx/logx.go b/pkg/logx/logx.go
index 3814ebe..17c5b62 100644
--- a/pkg/logx/logx.go
+++ b/pkg/logx/logx.go
@@ -3,12 +3,13 @@ package logx
 import (
 	"context"
 	"fmt"
-	"gitee.com/timedb/wheatCache/pkg/event"
-	middleMsg "gitee.com/timedb/wheatCache/pkg/middle-msg"
 	"os"
 	"runtime"
 	"strings"
 	"time"
+
+	"gitee.com/timedb/wheatCache/pkg/event"
+	middleMsg "gitee.com/timedb/wheatCache/pkg/middle-msg"
 )
 
 func With(ctx context.Context, p event.ProduceInterface) *upLogger {
@@ -41,15 +42,13 @@ func (l *upLogger) Panic(format string, msg ...interface{}) {
 
 func (l *upLogger) Print(level string, format string, msg ...interface{}) {
 	logPrint(4, level, format, msg...)
-
-	eventMiddle := event.NewEvent(middleMsg.EventNameLog)
-	eventMiddle.SetValue(middleMsg.MiddleMsgKey, middleMsg.LogContext{
+	sendMsg := &middleMsg.LogContext{
 		Level: level,
 		Data:  time.Now(),
 		Msg:   fmt.Sprintf(format, msg...),
 		Route: findPlace(4),
-	})
-	l.produce.Call(l.ctx, eventMiddle)
+	}
+	middleMsg.SendMiddleMsg(l.ctx, l.produce, sendMsg)
 }
 
 func (l *upLogger) Debugln(msg ...interface{}) {