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

debugging nats...

Browse Source
This commit is contained in:
Egor Aristov 2025-01-18 17:47:06 +03:00
parent 94694b2fee
commit 0c5ad7e692
Signed by: egor3f
GPG Key ID: 40482A264AAEC85F
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -26,10 +26,11 @@ func New(natsc *nats.Conn) (*NatsAdapter, error) {
return nil, fmt.Errorf("create jetstream: %w", err) return nil, fmt.Errorf("create jetstream: %w", err)
} }
jstream, err := jets.CreateStream(context.TODO(), jetstream.StreamConfig{ jstream, err := jets.CreateStream(context.TODO(), jetstream.StreamConfig{
Name: StreamName, Name: StreamName,
Subjects: []string{fmt.Sprintf("%s.>", SubjectPrefix)}, Subjects: []string{fmt.Sprintf("%s.>", SubjectPrefix)},
Retention: jetstream.WorkQueuePolicy, Retention: jetstream.WorkQueuePolicy,
Duplicates: DedupWindow, Duplicates: DedupWindow,
AllowDirect: true,
}) })
if err != nil { if err != nil {
return nil, fmt.Errorf("create js stream: %w", err) return nil, fmt.Errorf("create js stream: %w", err)