From 3b40794c2c5dd7ab722c730bbc8b9dff0644f1d0 Mon Sep 17 00:00:00 2001 From: Thibault Leroy Date: Tue, 18 Jun 2024 08:43:10 +0200 Subject: [PATCH] feat(consumer): log graceful shutdown --- consume.go | 1 + 1 file changed, 1 insertion(+) diff --git a/consume.go b/consume.go index 2e36e2e..d4eeba1 100644 --- a/consume.go +++ b/consume.go @@ -122,6 +122,7 @@ func (consumer *Consumer) Run(handler Handler) error { // Only call once. func (consumer *Consumer) Close() { if consumer.options.CloseGracefully { + consumer.options.Logger.Infof("waiting for handlers to finish...") err := consumer.waitForHandlers(context.Background()) if err != nil { consumer.options.Logger.Warnf("error while waiting for handler to finish: %v", err)