egor3f/rssalchemy
1
0
Fork 0
Code Actions Packages Releases Wiki Activity

remove nats-msg-id

Browse Source
This commit is contained in:
Egor Aristov 2025-01-19 17:34:56 +03:00
parent 0c5ad7e692
commit 031b062277
Signed by: egor3f
GPG Key ID: 40482A264AAEC85F
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/adapters/natsadapter/natsadapter.go
View File

@ -79,7 +79,7 @@ func (na *NatsAdapter) ProcessWorkCached(
ctx, ctx,
fmt.Sprintf("%s.%s", SubjectPrefix, cacheKey), fmt.Sprintf("%s.%s", SubjectPrefix, cacheKey),
taskPayload, taskPayload,
jetstream.WithMsgID(cacheKey), //jetstream.WithMsgID(cacheKey),
) )
if err != nil { if err != nil {
return nil, fmt.Errorf("nats publish error: %v", err) return nil, fmt.Errorf("nats publish error: %v", err)