From a268da1d12f4a48d9fbfb0f3c1c4ec5fcc050055 Mon Sep 17 00:00:00 2001
From: Ben Meier <ben.meier@humanitec.com>
Date: Tue, 25 Jun 2024 14:40:05 +0100
Subject: [PATCH] fix: initialise handlerMu in consumer (#169)

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

diff --git a/consume.go b/consume.go
index 805ae66..8d9b788 100644
--- a/consume.go
+++ b/consume.go
@@ -73,6 +73,7 @@ func NewConsumer(
 		reconnectErrCh:             reconnectErrCh,
 		closeConnectionToManagerCh: closeCh,
 		options:                    *options,
+		handlerMu:                  &sync.RWMutex{},
 		isClosedMu:                 &sync.RWMutex{},
 		isClosed:                   false,
 	}