AmqpReceiverOptions

Configures the AMQP Receiver.

Constructors

this
this()
Undocumented in source.
this
this(AmqpReceiverOptions other)
Undocumented in source.

Members

Functions

addCapability
AmqpReceiverOptions addCapability(string capability)

Adds a desired capability. A registry of commonly defined source capabilities and their meanings is maintained at <a href="http://www.amqp.org/specification/1.0/source-capabilities">AMQP Source Capabilities</a>.

getCapabilities
List!string getCapabilities()

Gets the list of desired capabilities for the source. A registry of commonly defined source capabilities and their meanings is maintained at <a href="http://www.amqp.org/specification/1.0/source-capabilities">AMQP Source Capabilities</a>.

getLinkName
string getLinkName()
Undocumented in source. Be warned that the author may not have intended to support it.
getMaxBufferedMessages
int getMaxBufferedMessages()

@return the max buffered messages

getQos
string getQos()

Gets the local QOS config, values can be {@code null}, {@code AT_MOST_ONCE} or {@code AT_LEAST_ONCE}.

isAutoAcknowledgement
bool isAutoAcknowledgement()

@return {@code true} if the auto-acknowledgement is enabled, {@code false} otherwise.

isDurable
bool isDurable()

@return if the receiver is durable.

isDynamic
bool isDynamic()

@return whether the receiver is using a dynamic address.

setAutoAcknowledgement
AmqpReceiverOptions setAutoAcknowledgement(bool aut)

Sets the auto-acknowledgement. When enabled (default), the messages are automatically acknowledged. If set to {@code false}, the messages must be acknowledged explicitly using {@link AmqpMessage#accepted()}, {@link AmqpMessage#released()} and {@link AmqpMessage#rejected()}.

setCapabilities
AmqpReceiverOptions setCapabilities(List!string capabilities)

Sets the list of desired capabilities A registry of commonly defined source capabilities and their meanings is maintained at <a href="http://www.amqp.org/specification/1.0/source-capabilities">AMQP Source Capabilities</a>.

setDurable
AmqpReceiverOptions setDurable(bool durable)

Sets the durability. <p> Passing {@code true} sets the expiry policy of the source to {@code NEVER} and the durability of the source to {@code UNSETTLED_STATE}.

setDynamic
AmqpReceiverOptions setDynamic(bool dynamic)

Sets whether the link remote terminus to be used should indicate it is 'dynamic', requesting the peer names it with a dynamic address. <p> The address provided by the peer can then be inspected using the {@link AmqpReceiver#address()} method on the {@link AmqpReceiver} received once opened.

setLinkName
AmqpReceiverOptions setLinkName(string linkName)
Undocumented in source. Be warned that the author may not have intended to support it.
setMaxBufferedMessages
AmqpReceiverOptions setMaxBufferedMessages(int maxBufferSize)

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

setQos
AmqpReceiverOptions setQos(string qos)

Sets the local QOS config.

Meta