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