public class AmqpSenderOptions extends Object
Constructor and Description |
---|
AmqpSenderOptions() |
AmqpSenderOptions(AmqpSenderOptions other) |
AmqpSenderOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
AmqpSenderOptions |
addCapability(String capability)
Adds a capability to be set on the sender target terminus.
|
List<String> |
getCapabilities()
Gets the list of capabilities to be set on the sender target terminus.
|
String |
getLinkName() |
boolean |
isAutoDrained()
Get whether the link will automatically be marked drained after the send queue drain handler fires in drain mode.
|
boolean |
isDynamic() |
AmqpSenderOptions |
setAutoDrained(boolean autoDrained)
Sets whether the link is automatically marked drained after the send queue drain handler callback
returns if the receiving peer requested that credit be drained.
|
AmqpSenderOptions |
setCapabilities(List<String> capabilities)
Sets the list of capabilities to be set on the sender target terminus.
|
AmqpSenderOptions |
setDynamic(boolean dynamic)
Sets whether the Target terminus to be used should specify it is 'dynamic',
requesting the peer creates a node and names it with a generated address.
|
AmqpSenderOptions |
setLinkName(String linkName) |
JsonObject |
toJson() |
public AmqpSenderOptions()
public AmqpSenderOptions(AmqpSenderOptions other)
public AmqpSenderOptions(JsonObject json)
public JsonObject toJson()
public String getLinkName()
public AmqpSenderOptions setLinkName(String linkName)
public boolean isDynamic()
public AmqpSenderOptions setDynamic(boolean dynamic)
The address provided by the peer can then be inspected using the
AmqpSender.address()
method on the AmqpSender
received once opened.
dynamic
- true if the sender should request dynamic creation of a node and address to send topublic boolean isAutoDrained()
setAutoDrained(boolean)
public AmqpSenderOptions setAutoDrained(boolean autoDrained)
true
by default.
autoDrained
- whether the link will automatically be drained after the send queue drain handler fires in drain modepublic List<String> getCapabilities()
public AmqpSenderOptions setCapabilities(List<String> capabilities)
capabilities
- the set of target capabilities.public AmqpSenderOptions addCapability(String capability)
capability
- the target capability to add, must not be null
Copyright © 2023 Eclipse. All rights reserved.