fix: dont automaticaly start consumer

vmihailenco · Nov 27, 2024 · dde6a3f · dde6a3f
1 parent 2956d04
commit dde6a3f
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/memqueue/queue.go b/memqueue/queue.go
@@ -88,15 +88,21 @@ 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{
 		opt: opt,
 	}
 
 	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