From 0880979403d074ef83fc4f463725dd5536619606 Mon Sep 17 00:00:00 2001 From: Fabrizio Sestito Date: Tue, 8 Oct 2024 18:25:50 +0200 Subject: [PATCH] chore(worker): use subject constant Signed-off-by: Fabrizio Sestito --- cmd/worker/main.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/cmd/worker/main.go b/cmd/worker/main.go index cdcd08e..a585818 100644 --- a/cmd/worker/main.go +++ b/cmd/worker/main.go @@ -7,22 +7,21 @@ import ( "time" "github.com/nats-io/nats.go" + "github.com/rancher/sbombastic/internal/messaging" ) func main() { - nc, err := nats.Connect("nats://controller-nats.sbombastic.svc.cluster.local") + nc, err := nats.Connect("nats://controller-nats.sbombastic.svc.cluster.local") if err != nil { log.Fatal(err) } - // Use the JetStream context to produce and consumer messages - // that have been persisted. js, err := nc.JetStream(nats.PublishAsyncMaxPending(256)) if err != nil { log.Fatal(err) } - sub, err := js.PullSubscribe("sbombastic", "worker", nats.InactiveThreshold(24*time.Hour)) + sub, err := js.PullSubscribe(messaging.SbombasticSubject, "worker", nats.InactiveThreshold(24*time.Hour)) if err != nil { log.Fatal(err) }