public interface ProtonHelper
Modifier and Type | Method and Description |
---|---|
static ProtonDelivery |
accepted(ProtonDelivery delivery,
boolean settle)
Accept the given delivery by applying Accepted disposition state, and optionally settling.
|
static org.apache.qpid.proton.amqp.transport.ErrorCondition |
condition(String condition,
String description)
Create an ErrorCondition with the given error condition value (which will be converted to the required Symbol type)
and error description string.
|
static org.apache.qpid.proton.amqp.transport.ErrorCondition |
condition(org.apache.qpid.proton.amqp.Symbol condition,
String description)
Create an ErrorCondition with the given error condition value and error description string.
|
static <T> io.vertx.core.AsyncResult<T> |
future(T value,
org.apache.qpid.proton.amqp.transport.ErrorCondition err) |
static org.apache.qpid.proton.message.Message |
message()
Creates a bare Message object.
|
static org.apache.qpid.proton.message.Message |
message(String body)
Creates a Message object with the given String contained as an AmqpValue body.
|
static org.apache.qpid.proton.message.Message |
message(String address,
String body)
Creates a Message object with the given String contained as an AmqpValue body, and the 'to' address set as given.
|
static ProtonDelivery |
modified(ProtonDelivery delivery,
boolean settle,
boolean deliveryFailed,
boolean undeliverableHere)
Modify the given delivery by applying Modified disposition state, with deliveryFailed and underliverableHere flags
as given, and optionally settling.
|
static ProtonDelivery |
rejected(ProtonDelivery delivery,
boolean settle)
Reject the given delivery by applying Rejected disposition state, and optionally settling.
|
static ProtonDelivery |
released(ProtonDelivery delivery,
boolean settle)
Release the given delivery by applying Released disposition state, and optionally settling.
|
static byte[] |
tag(String tag)
Creates a byte[] for use as a delivery tag by UTF-8 converting the given string.
|
static org.apache.qpid.proton.message.Message message()
static org.apache.qpid.proton.message.Message message(String body)
body
- the string to set as an AmqpValue bodystatic org.apache.qpid.proton.message.Message message(String address, String body)
address
- the 'to' address to setbody
- the string to set as an AmqpValue bodystatic org.apache.qpid.proton.amqp.transport.ErrorCondition condition(org.apache.qpid.proton.amqp.Symbol condition, String description)
AmqpError
,
ConnectionError
,
SessionError
and
LinkError
.condition
- the error condition valuedescription
- String description of the error, may be nullstatic org.apache.qpid.proton.amqp.transport.ErrorCondition condition(String condition, String description)
condition(Symbol, String)
for more details.condition
- the error condition value, to be converted to a Symboldescription
- String description of the error, may be nullstatic byte[] tag(String tag)
tag
- the string to convertstatic ProtonDelivery accepted(ProtonDelivery delivery, boolean settle)
delivery
- the delivery to updatesettle
- whether to settlestatic ProtonDelivery rejected(ProtonDelivery delivery, boolean settle)
delivery
- the delivery to updatesettle
- whether to settlestatic ProtonDelivery released(ProtonDelivery delivery, boolean settle)
delivery
- the delivery to updatesettle
- whether to settlestatic ProtonDelivery modified(ProtonDelivery delivery, boolean settle, boolean deliveryFailed, boolean undeliverableHere)
delivery
- the delivery to updatesettle
- whether to settledeliveryFailed
- whether the delivery should be treated as failedundeliverableHere
- whether the delivery is considered undeliverable by the related receiverstatic <T> io.vertx.core.AsyncResult<T> future(T value, org.apache.qpid.proton.amqp.transport.ErrorCondition err)
Copyright © 2019 Eclipse. All rights reserved.