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,