Forwarder: Write event to request

knative-extensions · Mar 18, 2024 · 4c29c06 · 4c29c06
1 parent cb942d1
commit 4c29c06
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/eventshub/forwarder/forwarder.go b/pkg/eventshub/forwarder/forwarder.go
@@ -26,6 +26,7 @@ import (
 	"time"
 
 	cloudevents "github.com/cloudevents/sdk-go/v2"
+	"github.com/cloudevents/sdk-go/v2/binding"
 	cloudeventsbindings "github.com/cloudevents/sdk-go/v2/binding"
 	"go.opencensus.io/trace"
 	"go.uber.org/zap"
@@ -171,6 +172,11 @@ func (o *Forwarder) ServeHTTP(writer http.ResponseWriter, request *http.Request)
 	}
 	req.URL = u
 
+	err = cehttp.WriteRequest(requestCtx, binding.ToMessage(event), req)
+	if err != nil {
+		logging.FromContext(o.ctx).Error("Cannot write the event to request: ", err)
+	}
+
 	eventString := "unknown"
 	if event != nil {
 		eventString = event.String()