dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix error handling in Ack 

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
This commit is contained in:
Tomasz Pietrek 2022-12-05 14:33:12 +01:00
parent 0463c2cf8b
commit 3a8a9a0ef6
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pubsub/jetstream/jetstream.go
View File

@ -37,7 +37,7 @@ func NewJetStream(logger logger.Logger) pubsub.PubSub {
return &jetstreamPubSub{l: logger}
}
func (js *jetstreamPubSub) Init(metadata pubsub.Metadata) error {
func (js *jetstreamPubSub) Init(metadata pubsub.Metadat) error {
var err error
js.meta, err = parseMetadata(metadata)
if err != nil {
@ -198,9 +198,9 @@ func (js *jetstreamPubSub) Subscribe(ctx context.Context, req pubsub.SubscribeRe
if js.meta.ackPolicy == nats.AckExplicitPolicy || js.meta.ackPolicy == nats.AckAllPolicy {
err = m.Ack()
}
if err != nil {
js.l.Errorf("Error while sending ACK for JetStream message %s/%d: %v", m.Subject, jsm.Sequence, err)
if err != nil {
js.l.Errorf("Error while sending ACK for JetStream message %s/%d: %v", m.Subject, jsm.Sequence, err)
}
}
}