From 86c0d10b1cbfa791bcb49763acd952d46e5c3d08 Mon Sep 17 00:00:00 2001
From: Egor Aristov <ef@efprojects.com>
Date: Sat, 18 Jan 2025 17:47:06 +0300
Subject: [PATCH] debugging nats...

---
 internal/adapters/natsadapter/natsadapter.go | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/internal/adapters/natsadapter/natsadapter.go b/internal/adapters/natsadapter/natsadapter.go
index 0e030ff..458c7fb 100644
--- a/internal/adapters/natsadapter/natsadapter.go
+++ b/internal/adapters/natsadapter/natsadapter.go
@@ -26,10 +26,11 @@ func New(natsc *nats.Conn) (*NatsAdapter, error) {
 		return nil, fmt.Errorf("create jetstream: %w", err)
 	}
 	jstream, err := jets.CreateStream(context.TODO(), jetstream.StreamConfig{
-		Name:       StreamName,
-		Subjects:   []string{fmt.Sprintf("%s.>", SubjectPrefix)},
-		Retention:  jetstream.WorkQueuePolicy,
-		Duplicates: DedupWindow,
+		Name:        StreamName,
+		Subjects:    []string{fmt.Sprintf("%s.>", SubjectPrefix)},
+		Retention:   jetstream.WorkQueuePolicy,
+		Duplicates:  DedupWindow,
+		AllowDirect: true,
 	})
 	if err != nil {
 		return nil, fmt.Errorf("create js stream: %w", err)