vertx / io.vertx.kotlin.amqp / amqpReceiverOptionsOf

amqpReceiverOptionsOf

fun amqpReceiverOptionsOf(autoAcknowledgement: Boolean? = null, capabilities: Iterable<String>? = null, capabilitys: Iterable<String>? = null, durable: Boolean? = null, dynamic: Boolean? = null, linkName: String? = null, maxBufferedMessages: Int? = null, qos: String? = null): AmqpReceiverOptions

A function providing a DSL for building io.vertx.amqp.AmqpReceiverOptions objects.

Configures the AMQP Receiver.

Parameters

autoAcknowledgement - Sets the auto-acknowledgement. When enabled (default), the messages are automatically acknowledged. If set to false, the messages must be acknowledged explicitly using io.vertx.amqp.AmqpMessage, io.vertx.amqp.AmqpMessage and io.vertx.amqp.AmqpMessage.

capabilities - Sets the list of desired capabilities A registry of commonly defined source capabilities and their meanings is maintained at AMQP Source Capabilities.

capabilitys - Adds a desired capability. A registry of commonly defined source capabilities and their meanings is maintained at AMQP Source Capabilities.

durable - Sets the durability. Passing true sets the expiry policy of the source to NEVER and the durability of the source to UNSETTLED_STATE.

dynamic - Sets whether the link remote terminus to be used should indicate it is 'dynamic', requesting the peer names it with a dynamic address. The address provided by the peer can then be inspected using the io.vertx.amqp.AmqpReceiver method on the io.vertx.amqp.AmqpReceiver received once opened.

linkName -

maxBufferedMessages - Sets the max buffered messages. This message can be used to configure the initial credit of a receiver.

qos - Sets the local QOS config.