From 3a6a11ac710d98667bdc4d252f91b00b24199030 Mon Sep 17 00:00:00 2001
From: postmannen <postmannen@gmail.com>
Date: Thu, 21 Nov 2024 22:23:24 +0100
Subject: [PATCH] added FilterSubjects

---
 processes.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/processes.go b/processes.go
index ea55b7f..5744c6d 100644
--- a/processes.go
+++ b/processes.go
@@ -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)