Graceful Exit

Deeptiman · Deeptiman · commit af8503d2da48 · 2021-07-17T01:43:04.000+05:30
diff --git a/consumer.go b/consumer.go
@@ -99,8 +99,8 @@ func (c *BatchConsumer) StartConsumer() {
 
 	signal.Notify(c.TerminateCh, syscall.SIGINT, syscall.SIGTERM)
 	<-c.TerminateCh
-
 	cancel()
+	os.Exit(0)
 	c.Workerline.Wait()
 }
 

Original file line number	Diff line number	Diff line change
`@@ -99,8 +99,8 @@ func (c *BatchConsumer) StartConsumer() {`
`99`	`99`
`100`	`100`	`signal.Notify(c.TerminateCh, syscall.SIGINT, syscall.SIGTERM)`
`101`	`101`	`<-c.TerminateCh`
`102`		`-`
`103`	`102`	`cancel()`
	`103`	`+ os.Exit(0)`
`104`	`104`	`c.Workerline.Wait()`
`105`	`105`	`}`
`106`	`106`