suspend fun RabbitMQClient.basicQosAwait(prefetchCount: Int): Unit
Request a specific prefetchCount "quality of service" settings for this channel.
prefetchCount - maximum number of messages that the server will deliver, 0 if unlimited
resultHandler - handler called when operation is done with a result of the operation
suspend fun RabbitMQClient.basicQosAwait(prefetchCount: Int, global: Boolean): Unit
Request a specific prefetchCount "quality of service" settings for this channel.
prefetchCount - maximum number of messages that the server will deliver, 0 if unlimited
global - true if the settings should be applied to the entire channel rather than each consumer
resultHandler - handler called when operation is done with a result of the operation
suspend fun RabbitMQClient.basicQosAwait(prefetchSize: Int, prefetchCount: Int, global: Boolean): Unit
Request specific "quality of service" settings.
These settings impose limits on the amount of data the server will deliver to consumers before requiring acknowledgements. Thus they provide a means of consumer-initiated flow control.
prefetchSize - maximum amount of content (measured in octets) that the server will deliver, 0 if unlimited
prefetchCount - maximum number of messages that the server will deliver, 0 if unlimited
global - true if the settings should be applied to the entire channel rather than each consumer
resultHandler - handler called when operation is done with a result of the operation