Merge pull request #935 from yanmxa/br_mqtt_ext

Clean up the previous user properties from MQTT protocol
cloudevents · Sep 18, 2023 · 28780a7 · 28780a7
2 parents 238c545 + 4bcddda
commit 28780a7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/protocol/mqtt_paho/v2/write_message.go b/protocol/mqtt_paho/v2/write_message.go
@@ -58,10 +58,10 @@ func (b *pubMessageWriter) SetStructuredEvent(ctx context.Context, f format.Form
 
 func (b *pubMessageWriter) Start(ctx context.Context) error {
 	if b.Properties == nil {
-		b.Properties = &paho.PublishProperties{
-			User: make([]paho.UserProperty, 0),
-		}
+		b.Properties = &paho.PublishProperties{}
 	}
+	// the UserProperties of publish message is used to load event extensions
+	b.Properties.User = make([]paho.UserProperty, 0)
 	return nil
 }