fix(memqueue): Dont automaticaly start consumer

vmihailenco · Nov 27, 2024 · baf5faf · baf5faf
1 parent 2956d04
commit baf5faf
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