From be7ec3cd0ee36b672e7b22f9cf2cc7258524cce3 Mon Sep 17 00:00:00 2001
From: Mike Mason <mimason@equinix.com>
Date: Wed, 19 Jul 2023 18:10:02 +0000
Subject: [PATCH] whoopsied the queue group

---
 internal/pubsub/nats.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/pubsub/nats.go b/internal/pubsub/nats.go
index 3c642c7..ed3e2ec 100644
--- a/internal/pubsub/nats.go
+++ b/internal/pubsub/nats.go
@@ -123,6 +123,7 @@ func newSubscriber(ctx context.Context, config events.SubscriberConfig, logger *
 		logger:              logger,
 		nats:                conn,
 		jetstream:           js,
+		queueGroup:          config.QueueGroup,
 		topicPrefix:         config.Prefix,
 		subscriptionOptions: subOptions,
 		context:             ctx,