fix(amqp): Return error when channel is closed. Fixes #920 (#925)

* fix(amqp): Return error when channel is closed. Fixes #920 * message
argoproj · Nov 4, 2020 · e64eaaa · e64eaaa
1 parent 6efb0e0
commit e64eaaa
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/eventsources/sources/amqp/start.go b/eventsources/sources/amqp/start.go
@@ -106,7 +106,11 @@ func (el *EventListener) StartListening(ctx context.Context, dispatch func([]byt
 	log.Info("listening to messages on channel...")
 	for {
 		select {
-		case msg := <-delivery:
+		case msg, ok := <-delivery:
+			if !ok {
+				log.Error("failed to read a message, channel might have been closed")
+				return errors.New("channel might have been closed")
+			}
 			log.Info("received the message", zap.Any("message-id", msg.MessageId))
 			body := &events.AMQPEventData{
 				ContentType:     msg.ContentType,