From e564b431ff38cee58ad756b7688e4f3c870eead1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Johannes=20W=C3=BCrbach?= <johannes.wuerbach@googlemail.com>
Date: Tue, 19 Mar 2024 10:00:42 +0100
Subject: [PATCH] fix: consumer close before run

---
 consume.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/consume.go b/consume.go
index 4517c5d..ab6b692 100644
--- a/consume.go
+++ b/consume.go
@@ -131,6 +131,8 @@ func (consumer *Consumer) startGoroutines(
 	handler Handler,
 	options ConsumerOptions,
 ) error {
+	consumer.isClosedMux.Lock()
+	defer consumer.isClosedMux.Unlock()
 	err := consumer.chanManager.QosSafe(
 		options.QOSPrefetch,
 		0,