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 }