ProtonHelper

Members

Static functions

accepted

ProtonDelivery accepted(ProtonDelivery delivery, bool settle)

Accept the given delivery by applying Accepted disposition state, and optionally settling.

condition

ErrorCondition condition(Symbol condition, String description)

Create an ErrorCondition with the given error condition value and error description string.

condition

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.

future

AsyncResult!T future(T value, ErrorCondition err)

Undocumented in source. Be warned that the author may not have intended to support it.

message

Message message()

Creates a bare Message object.

message

Message message(String bd)

Creates a Message object with the given String contained as an AmqpValue body.

message

Message message(String address, String bd)

Creates a Message object with the given String contained as an AmqpValue body, and the 'to' address set as given.

modified

ProtonDelivery modified(ProtonDelivery delivery, bool settle, bool deliveryFailed, bool undeliverableHere)

Modify the given delivery by applying Modified disposition state, with deliveryFailed and underliverableHere flags as given, and optionally settling.

rejected

ProtonDelivery rejected(ProtonDelivery delivery, bool settle)

Reject the given delivery by applying Rejected disposition state, and optionally settling.

released

ProtonDelivery released(ProtonDelivery delivery, bool settle)

Release the given delivery by applying Released disposition state, and optionally settling.

tag

byte[] tag(String tag)

Creates a byte[] for use as a delivery tag by UTF-8 converting the given string.

• ProtonHelper