From dde6a3fd8995114b5924092fe0ef7d9a4b7b03f3 Mon Sep 17 00:00:00 2001
From: Ryan Murray <rymurr@gmail.com>
Date: Wed, 27 Nov 2024 10:08:19 +0100
Subject: [PATCH] fix: dont automaticaly start consumer

---
 memqueue/queue.go | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/memqueue/queue.go b/memqueue/queue.go
index 844dafe..ee02f5a 100644
--- a/memqueue/queue.go
+++ b/memqueue/queue.go
@@ -88,6 +88,10 @@ type Queue struct {
 var _ taskq.Queue = (*Queue)(nil)
 
 func NewQueue(opt *taskq.QueueOptions) *Queue {
+	return NewQueueMaybeConsumer(true, opt)
+}
+
+func NewQueueMaybeConsumer(startConsumer bool, opt *taskq.QueueOptions) *Queue {
 	opt.Init()
 
 	q := &Queue{
@@ -95,8 +99,10 @@ func NewQueue(opt *taskq.QueueOptions) *Queue {
 	}
 
 	q.consumer = taskq.NewConsumer(q)
-	if err := q.consumer.Start(context.Background()); err != nil {
-		panic(err)
+	if startConsumer {
+		if err := q.consumer.Start(context.Background()); err != nil {
+			panic(err)
+		}
 	}
 
 	return q