From 2d80a5b73c47d45b4cf12b5bb0ab89a021b23a09 Mon Sep 17 00:00:00 2001
From: Ta-Ching Chen <contact@tachingchen.com>
Date: Sun, 25 Nov 2018 10:07:46 +0800
Subject: [PATCH] Fix MQ trigger (NATS) wrongly sends error message to response
 topic (#1002)

---
 mqtrigger/messageQueue/nats.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/mqtrigger/messageQueue/nats.go b/mqtrigger/messageQueue/nats.go
index 943ec461a..4e36df4a2 100644
--- a/mqtrigger/messageQueue/nats.go
+++ b/mqtrigger/messageQueue/nats.go
@@ -165,6 +165,7 @@ func msgHandler(nats *Nats, trigger *crd.MessageQueueTrigger) func(*ns.Msg) {
 					// this may cause message loss
 				}
 			}
+			return
 		}
 
 		// Trigger acks message only if a request was processed successfully