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 9bfe51f9c8
commit 86c0d10b1c
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)
}
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)