eventhubs metadata propagation

tanvigour · tanvigour · commit 290369591b42 · 2021-07-12T19:14:37.000-04:00
diff --git a/bindings/azure/eventhubs/eventhubs.go b/bindings/azure/eventhubs/eventhubs.go
@@ -198,10 +198,11 @@ func (a *AzureEventHubs) RegisterPartitionedEventProcessor(handler func(*binding
 		return err
 	}
 
-	callback := func(c context.Context, event *eventhub.Event) error {
+	callback := func(c context.Context, event *eventhub.Event, bind *bindings.InvokeResponse) error {
 		if event != nil {
 			handler(&bindings.ReadResponse{
 				Data: event.Data,
+				Metadata : bind.metadata,
 			})
 		}
 

Original file line number	Diff line number	Diff line change
`@@ -198,10 +198,11 @@ func (a AzureEventHubs) RegisterPartitionedEventProcessor(handler func(binding`
`198`	`198`	`return err`
`199`	`199`	`}`
`200`	`200`
`201`		`- callback := func(c context.Context, event *eventhub.Event) error {`
	`201`	`+ callback := func(c context.Context, event eventhub.Event, bind bindings.InvokeResponse) error {`
`202`	`202`	`if event != nil {`
`203`	`203`	`handler(&bindings.ReadResponse{`
`204`	`204`	`Data: event.Data,`
	`205`	`+ Metadata : bind.metadata,`
`205`	`206`	`})`
`206`	`207`	`}`
`207`	`208`