diff --git a/pkg/dispatcher/dispatcher.go b/pkg/dispatcher/dispatcher.go index 3f6b156ea9..16398b4acc 100644 --- a/pkg/dispatcher/dispatcher.go +++ b/pkg/dispatcher/dispatcher.go @@ -198,6 +198,7 @@ func (d *Dispatcher) dispatch(ctx context.Context, msg amqp.Delivery, ceClient c if !isSuccess { logging.FromContext(ctx).Warnf("Failed to deliver to %q", d.SubscriberURL) msg.Headers["knativeerrordest"] = d.SubscriberURL + msg.Headers["knativeerrorcode"] = statusCode if err = msg.Nack(false, true); err != nil { logging.FromContext(ctx).Warn("failed to NACK event: ", err) }