From c3163cfa060b9bf8b26322503d65f1d9c5a9e806 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E4=BC=9F=E4=B9=90?= <mogfee@163.com>
Date: Mon, 27 Mar 2023 10:45:19 +0800
Subject: [PATCH] x

---
 log/mq/nsq.go | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/log/mq/nsq.go b/log/mq/nsq.go
index a9696b0..72a02ec 100644
--- a/log/mq/nsq.go
+++ b/log/mq/nsq.go
@@ -19,7 +19,7 @@ type nsqLogger struct {
 	stop   atomic.Bool
 }
 
-func (s *nsqLogger) Start() error {
+func (s *nsqLogger) Start(ctx context.Context) error {
 	xgo.Go(func() {
 		for v := range s.list {
 			if s.stop.Load() {
@@ -35,11 +35,10 @@ func (s *nsqLogger) Start() error {
 			}(v)
 		}
 	})
-	fmt.Println("xx")
 	return nil
 }
 
-func (s *nsqLogger) Shutdown(ctx context.Context) error {
+func (s *nsqLogger) Stop(ctx context.Context) error {
 	if s.stop.Load() {
 		return nil
 	}