Skip to content

Commit d06aea7

Browse files
committed
clean the the previous properties
Signed-off-by: Meng Yan <myan@redhat.com>
1 parent 754a26b commit d06aea7

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

protocol/mqtt_paho/v2/protocol.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,7 @@ func (p *Protocol) Send(ctx context.Context, m binding.Message, transformers ...
9090
defer m.Finish(err)
9191

9292
msg := p.publishOption
93+
msg.Properties.User = make(paho.UserProperties, 0)
9394
if cecontext.TopicFrom(ctx) != "" {
9495
msg.Topic = cecontext.TopicFrom(ctx)
9596
cecontext.WithTopic(ctx, "")

0 commit comments

Comments
 (0)