Merge pull request #170 from astromechza/fix-169

wagslane · web-flow · commit ef6a38050e8e · 2024-06-25T07:43:47.000-06:00
fix: initialise handlerMu in consumer (#169)
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`	`}`