Johannes Würbach
2 years ago
No known key found for this signature in database
GPG Key ID: 74DB0F4D956CCCE3
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, |
|
|
|
|
