From c476f54a6c73086ae765487efe1f2edbe02aa75f 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 943ec461..4e36df4a 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