mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-31 01:24:31 +00:00
Code Activity

added FilterSubjects

Browse source
This commit is contained in:
postmannen 2024-11-21 22:23:24 +01:00
parent 6a0fdaf3ab
commit 3a6a11ac71
1 changed files with 3 additions and 2 deletions

5
processes.go
View file

@ -386,8 +386,9 @@ func (p *processes) Start(proc process) {
}
consumer, err := stream.CreateOrUpdateConsumer(proc.ctx, jetstream.ConsumerConfig{
Name: "order_processor",
Durable: "order_processor",
Name: "order_processor",
Durable: "order_processor",
FilterSubjects: []string{fmt.Sprintf("nodes.%v", proc.server.nodeName), "nodes.all"},
})
if err != nil {
log.Fatalf("error: create or update consumer failed: %v\n", err)