Skip to content

Commit 544e1e9

Browse files
authored
fix: error on closing the consumer (#27)
1 parent de4bc95 commit 544e1e9

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

internal/consumer/rabbitmq/consumer.go

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -239,7 +239,15 @@ func (r *rabbitMQ) Consume(ctx context.Context,
239239
"consumer_meta": meta,
240240
}).Info("stopping the worker")
241241
return
242-
case receivedMsg := <-r.msgReceiver:
242+
case receivedMsg, ok := <-r.msgReceiver:
243+
if !ok {
244+
// deliveries channel closed (e.g., due to Stop/Cancel or connection closure)
245+
logrus.WithFields(logrus.Fields{
246+
"queue_name": r.option.QueueName,
247+
"consumer_meta": meta,
248+
}).Info("message receiver closed, stopping the worker")
249+
return
250+
}
243251
msg, err := buildMessage(meta, receivedMsg)
244252
if err != nil {
245253
if err == errors.ErrInvalidMessageFormat {

0 commit comments

Comments
 (0)