queueBind

abstract suspend fun queueBind(queue: String, exchange: String, routingKey: String = "", arguments: Table = emptyMap()): AMQPResponse.Channel.Queue.Bound

Binds a queue to an exchange.

Return

AMQPResponse.Channel.Queue.Bound confirming that broker has accepted the request.

Parameters

queue

Name of the queue.

exchange

Name of the exchange.

routingKey

Bind only to messages matching routingKey.

arguments

Bind only to messages matching given options.