Nack if there's a header

knative-extensions · Jul 15, 2023 · 095834a · 095834a
1 parent 0c426b7
commit 095834a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/dispatcher/dispatcher.go b/pkg/dispatcher/dispatcher.go
@@ -152,7 +152,7 @@ func getStatus(ctx context.Context, result protocol.Result) (int, bool) {
 
 func (d *Dispatcher) dispatch(ctx context.Context, msg amqp.Delivery, ceClient cloudevents.Client) {
 	start := time.Now()
-	if _, ok := msg.Headers["knativeerrordest"]; !ok {
+	if _, ok := msg.Headers["knativeerrordest"]; ok {
 		err := msg.Nack(false, false)
 		if err != nil {
 			logging.FromContext(ctx).Warn("failed to NACK event: ", err)