public class AmqpReceiverOptions extends Object
Constructor and Description |
---|
AmqpReceiverOptions() |
AmqpReceiverOptions(AmqpReceiverOptions other) |
AmqpReceiverOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
AmqpReceiverOptions |
addCapability(String capability)
Adds a capability to be set on the receiver source terminus.
|
List<String> |
getCapabilities()
Gets the list of capabilities to be set on the receiver source terminus.
|
String |
getLinkName() |
int |
getMaxBufferedMessages() |
String |
getQos()
Gets the local QOS config, values can be
null , AT_MOST_ONCE or AT_LEAST_ONCE . |
String |
getSelector() |
boolean |
isAutoAcknowledgement() |
boolean |
isDurable() |
boolean |
isDynamic() |
boolean |
isNoLocal() |
AmqpReceiverOptions |
setAutoAcknowledgement(boolean auto)
Sets the auto-acknowledgement.
|
AmqpReceiverOptions |
setCapabilities(List<String> capabilities)
Sets the list of capabilities to be set on the receiver source terminus.
|
AmqpReceiverOptions |
setDurable(boolean durable)
Sets the durability.
|
AmqpReceiverOptions |
setDynamic(boolean dynamic)
Sets whether the Source terminus to be used should specify it is 'dynamic',
requesting the peer creates a node and names it with a generated address.
|
AmqpReceiverOptions |
setLinkName(String linkName) |
AmqpReceiverOptions |
setMaxBufferedMessages(int maxBufferSize)
Sets the max buffered messages.
|
AmqpReceiverOptions |
setNoLocal(boolean noLocal)
Sets whether this receiver should not receive messages that were sent using the same underlying connection.
|
AmqpReceiverOptions |
setQos(String qos)
Sets the local QOS config.
|
AmqpReceiverOptions |
setSelector(String selector)
Sets a message selector string.
|
JsonObject |
toJson() |
public AmqpReceiverOptions()
public AmqpReceiverOptions(AmqpReceiverOptions other)
public AmqpReceiverOptions(JsonObject json)
public JsonObject toJson()
public String getLinkName()
public AmqpReceiverOptions setLinkName(String linkName)
public boolean isDynamic()
public AmqpReceiverOptions setDynamic(boolean dynamic)
The address provided by the peer can then be inspected using the
AmqpReceiver.address()
method on the AmqpReceiver
received once opened.
dynamic
- true if the receiver should request dynamic creation of a node and address to consume frompublic String getQos()
null
, AT_MOST_ONCE
or AT_LEAST_ONCE
.public AmqpReceiverOptions setQos(String qos)
qos
- the local QOS config. Accepted values are: null
, AT_MOST_ONCE
or AT_LEAST_ONCE
.public List<String> getCapabilities()
public AmqpReceiverOptions setCapabilities(List<String> capabilities)
capabilities
- the set of source capabilities.public AmqpReceiverOptions addCapability(String capability)
capability
- the source capability to add, must not be null
public boolean isDurable()
public AmqpReceiverOptions setDurable(boolean durable)
Passing true
sets the expiry policy of the source to NEVER
and the durability of the source
to UNSETTLED_STATE
.
durable
- whether or not the receiver must indicate it's durablepublic int getMaxBufferedMessages()
public AmqpReceiverOptions setMaxBufferedMessages(int maxBufferSize)
maxBufferSize
- the max buffered size, must be positive. If not set, default credit is used.AmqpReceiverOptions
instance.public boolean isAutoAcknowledgement()
true
if the auto-acknowledgement is enabled, false
otherwise.public AmqpReceiverOptions setAutoAcknowledgement(boolean auto)
false
, the messages must
be acknowledged explicitly using AmqpMessage.accepted()
, AmqpMessage.released()
and
AmqpMessage.rejected()
.auto
- whether or not the auto-acknowledgement should be enabled.AmqpReceiverOptions
instance.public String getSelector()
public AmqpReceiverOptions setSelector(String selector)
selector
- the selector string to set.public boolean isNoLocal()
public AmqpReceiverOptions setNoLocal(boolean noLocal)
noLocal
- true if this receiver shall not receive messages that were sent on the same underlying connectionCopyright © 2023 Eclipse. All rights reserved.