Reconnect when Ack or Reject failure to avoid infinite loop on forwar…

…ding messages already in channel (#21)
AirHelp · Nov 7, 2017 · 0668679 · 0668679
1 parent a60ce6a
commit 0668679
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/rabbitmq/consumer.go b/rabbitmq/consumer.go
@@ -167,6 +167,7 @@ func (c Consumer) startForwarding(params *workerParams) error {
 					log.WithFields(log.Fields{
 						"forwarderName": forwarderName,
 						"error":         err.Error()}).Error("Could not reject message")
+					return err
 				}
 
 			} else {
@@ -175,6 +176,7 @@ func (c Consumer) startForwarding(params *workerParams) error {
 						"forwarderName": forwarderName,
 						"error":         err.Error(),
 						"messageID":     d.MessageId}).Error("Could not ack message")
+					return err
 				}
 			}
 		case <-params.check: