Fix MQ trigger (NATS) wrongly sends error message to response topic (#1002)

2018-11-25 10:07:46 +08:00
parent 4b5ab0ad93
commit c476f54a6c
1 changed files with 1 additions and 0 deletions
@@ -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