RetroSearch Browse

Showing content from https://github.com/cloudevents/sdk-go/commit/4bcdddaf15968c0ad64fd04d417984eb3e1838f1 below:

File tree Expand file treeCollapse file tree 2 files changed

-4

lines changed

Filter options

Expand file treeCollapse file tree 2 files changed

-4

lines changed Original file line number Diff line number Diff line change


 @@ -90,7 +90,6 @@ func (p *Protocol) Send(ctx context.Context, m binding.Message, transformers ...

90 90


 defer m.Finish(err)

91 91 92 92


 msg := p.publishOption

93

-
 msg.Properties.User = make(paho.UserProperties, 0)

94 93


 if cecontext.TopicFrom(ctx) != "" {

95 94


 msg.Topic = cecontext.TopicFrom(ctx)

96 95


 cecontext.WithTopic(ctx, "")

Original file line number Diff line number Diff line change


 @@ -58,10 +58,10 @@ func (b *pubMessageWriter) SetStructuredEvent(ctx context.Context, f format.Form

58 58 59 59


 func (b *pubMessageWriter) Start(ctx context.Context) error {

60 60


 if b.Properties == nil {

61

-
 b.Properties = &paho.PublishProperties{

62

-
 User: make([]paho.UserProperty, 0),

63

-
 }

61

+
 b.Properties = &paho.PublishProperties{}

64 62

63

+
 // the UserProperties of publish message is used to load event extensions

64

+
 b.Properties.User = make([]paho.UserProperty, 0)

65 65


 return nil

66 66

67 67

You can’t perform that action at this time.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4