fix: initialise handlerMu in consumer (#169)

astromechza · astromechza · commit a268da1d12f4 · 2024-06-25T14:40:05.000+01:00
diff --git 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,
 	}

Original file line number	Diff line number	Diff line change
`@@ -73,6 +73,7 @@ func NewConsumer(`
`73`	`73`	`reconnectErrCh: reconnectErrCh,`
`74`	`74`	`closeConnectionToManagerCh: closeCh,`
`75`	`75`	`options: *options,`
	`76`	`+ handlerMu: &sync.RWMutex{},`
`76`	`77`	`isClosedMu: &sync.RWMutex{},`
`77`	`78`	`isClosed: false,`
`78`	`79`	`}`