The QueuePublisher constructor invocation in RabbitConnection.consume(...) does not allow the caller to configure the qos property on the channel (the prefetch argument has a default value of 20 and is not overridden).
Happy to submit a PR, but what do we want the API to look like? Do we want this to be configurable or an argument on .consume(...)?
The
QueuePublisherconstructor invocation inRabbitConnection.consume(...)does not allow the caller to configure the qos property on the channel (theprefetchargument has a default value of 20 and is not overridden).Happy to submit a PR, but what do we want the API to look like? Do we want this to be configurable or an argument on
.consume(...)?