From 031b06227784aea9724e51aa7709742982012b27 Mon Sep 17 00:00:00 2001 From: Egor Aristov Date: Sun, 19 Jan 2025 17:34:56 +0300 Subject: [PATCH] remove nats-msg-id --- internal/adapters/natsadapter/natsadapter.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/adapters/natsadapter/natsadapter.go b/internal/adapters/natsadapter/natsadapter.go index 458c7fb..3c0c99e 100644 --- a/internal/adapters/natsadapter/natsadapter.go +++ b/internal/adapters/natsadapter/natsadapter.go @@ -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)