We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 15bc96b commit 3b40794Copy full SHA for 3b40794
consume.go
@@ -122,6 +122,7 @@ func (consumer *Consumer) Run(handler Handler) error {
122
// Only call once.
123
func (consumer *Consumer) Close() {
124
if consumer.options.CloseGracefully {
125
+ consumer.options.Logger.Infof("waiting for handlers to finish...")
126
err := consumer.waitForHandlers(context.Background())
127
if err != nil {
128
consumer.options.Logger.Warnf("error while waiting for handler to finish: %v", err)
0 commit comments