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 86c0d10b1c
commit bf88ba1a36
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,
fmt.Sprintf("%s.%s", SubjectPrefix, cacheKey),
taskPayload,
jetstream.WithMsgID(cacheKey),
//jetstream.WithMsgID(cacheKey),
)
if err != nil {
return nil, fmt.Errorf("nats publish error: %v", err)