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)