Update queue.go

kevwan · web-flow · commit 9cdcaf59edd6 · 2024-07-20T23:06:00.000+08:00
diff --git a/kq/queue.go b/kq/queue.go
@@ -192,7 +192,7 @@ func (q *kafkaQueue) Start() {
 		close(q.channel)
 		q.consumerRoutines.Wait()
     
-    logx.Infof("Consumer %s is closed", q.c.Name)
+		logx.Infof("Consumer %s is closed", q.c.Name)
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -192,7 +192,7 @@ func (q *kafkaQueue) Start() {`
`192`	`192`	`close(q.channel)`
`193`	`193`	`q.consumerRoutines.Wait()`
`194`	`194`
`195`		`- logx.Infof("Consumer %s is closed", q.c.Name)`
	`195`	`+ logx.Infof("Consumer %s is closed", q.c.Name)`
`196`	`196`	`}`
`197`	`197`	`}`
`198`	`198`