Forgot the status code

knative-extensions · Jul 10, 2023 · 0c426b7 · 0c426b7
1 parent 30fdc1b
commit 0c426b7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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)
 		}