Browse Source
Merge pull request #159 from johanneswuerbach/fix-close-race
fix: consumer close before run
pull/170/head
Lane Wagner
1 year ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with
2 additions and
0 deletions
-
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, |
|
|
|
|
