clean the the previous properties

Signed-off-by: Meng Yan <myan@redhat.com>
cloudevents · Sep 13, 2023 · d06aea7 · d06aea7
1 parent 754a26b
commit d06aea7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/protocol/mqtt_paho/v2/protocol.go b/protocol/mqtt_paho/v2/protocol.go
@@ -90,6 +90,7 @@ func (p *Protocol) Send(ctx context.Context, m binding.Message, transformers ...
 	defer m.Finish(err)
 
 	msg := p.publishOption
+	msg.Properties.User = make(paho.UserProperties, 0)
 	if cecontext.TopicFrom(ctx) != "" {
 		msg.Topic = cecontext.TopicFrom(ctx)
 		cecontext.WithTopic(ctx, "")