| Overview |  |
amqp10_body() = [#'v1_0.data'{}] | [#'v1_0.amqp_sequence'{}] | #'v1_0.amqp_value'{}
amqp10_header() = #{durable => boolean(), priority => byte(), ttl => opt(non_neg_integer()), first_acquirer => boolean(), delivery_count => non_neg_integer()}
abstract datatype: amqp10_msg()
amqp10_properties() = #{message_id => opt(any()), user_id => opt(binary()), to => opt(any()), subject => opt(binary()), reply_to => opt(any()), correlation_id => opt(any()), content_type => opt(content_type()), content_encoding => opt(content_encoding()), absolute_expiry_time => opt(non_neg_integer()), creation_time => opt(non_neg_integer()), group_id => opt(binary()), group_sequence => opt(non_neg_integer()), reply_to_group_id => opt(binary())}
annotations_key() = binary() | non_neg_integer()
content_encoding() = term()
content_type() = term()
delivery_tag() = binary()
header_key() = durable | priority | ttl | first_acquirer | delivery_count
opt(T) = T | undefined
| application_properties/1 | |
| body/1 | |
| body_bin/1 | Returns the binary representation. |
| delivery_annotations/1 | |
| delivery_id/1 | |
| delivery_tag/1 | |
| footer/1 | |
| from_amqp_records/1 | |
| handle/1 | |
| header/2 | |
| headers/1 | |
| message_annotations/1 | |
| message_format/1 | |
| new/2 | Create a new settled amqp10 message using the specified delivery tag and body. |
| new/3 | Create a new amqp10 message using the specified delivery tag, body and settlement state. |
| properties/1 | |
| set_application_properties/2 | |
| set_delivery_annotations/2 | |
| set_handle/2 | Set the link handle used for the message transfer. |
| set_headers/2 | Set amqp message headers. |
| set_message_annotations/2 | |
| set_message_format/2 | Set the message format. |
| set_properties/2 | Set amqp message properties. |
| set_settled/2 | Set the settledment mode. |
| settled/1 | |
| to_amqp_records/1 |
application_properties(Amqp10_msg::amqp10_msg()) -> #{binary() => binary() | integer() | string()}
body(Amqp10_msg::amqp10_msg()) -> [binary()] | [#'v1_0.amqp_sequence'{}] | #'v1_0.amqp_value'{}
body_bin(Amqp10_msg::amqp10_msg()) -> binary()
Returns the binary representation
delivery_annotations(Amqp10_msg::amqp10_msg()) -> #{annotations_key() => any()}
delivery_id(Amqp10_msg::amqp10_msg()) -> non_neg_integer()
delivery_tag(Amqp10_msg::amqp10_msg()) -> delivery_tag()
footer(Amqp10_msg::amqp10_msg()) -> #{annotations_key() => any()}
from_amqp_records(Records::[amqp10_client_types:amqp10_msg_record()]) -> amqp10_msg()
handle(Amqp10_msg::amqp10_msg()) -> non_neg_integer()
header(K::header_key(), Amqp10_msg::amqp10_msg()) -> term()
headers(Amqp10_msg::amqp10_msg()) -> amqp10_header()
message_annotations(Amqp10_msg::amqp10_msg()) -> #{annotations_key() => any()}
message_format(Amqp10_msg::amqp10_msg()) -> opt({non_neg_integer(), non_neg_integer()})
new(DeliveryTag::delivery_tag(), Body::amqp10_body() | binary()) -> amqp10_msg()
Create a new settled amqp10 message using the specified delivery tag and body.
new(DeliveryTag::delivery_tag(), Body::amqp10_body() | binary(), Settled::boolean()) -> amqp10_msg()
Create a new amqp10 message using the specified delivery tag, body and settlement state. Settled=true means the message is considered settled as soon as sent and no disposition will be issued by the receiver. Settled=false will delay settlement until a disposition has been received. A disposition will be notified to the sender by a message of the following stucture: {amqp10_disposition, {accepted | rejected, DeliveryTag}}
properties(Amqp10_msg::amqp10_msg()) -> amqp10_properties()
set_application_properties(Props::#{binary() | string() => binary() | integer() | string()}, Amqp10_msg::amqp10_msg()) -> amqp10_msg()
set_delivery_annotations(Props::#{binary() => binary() | integer() | string()}, Amqp10_msg::amqp10_msg()) -> amqp10_msg()
set_handle(Handle::non_neg_integer(), Amqp10_msg::amqp10_msg()) -> amqp10_msg()
Set the link handle used for the message transfer.
set_headers(Headers::#{atom() => any()}, Amqp10_msg::amqp10_msg()) -> amqp10_msg()
Set amqp message headers.
set_message_annotations(Props::#{binary() => binary() | number() | string() | tuple()}, Amqp10_msg::amqp10_msg()) -> amqp10_msg()
set_message_format(X1::{non_neg_integer(), non_neg_integer()}, Amqp10_msg::amqp10_msg()) -> amqp10_msg()
Set the message format.
set_properties(Props::amqp10_properties(), Amqp10_msg::amqp10_msg()) -> amqp10_msg()
Set amqp message properties.
set_settled(Settled::boolean(), Amqp10_msg::amqp10_msg()) -> amqp10_msg()
Set the settledment mode. Settled=true means the message is considered settled as soon as sent and no disposition will be issued by the receiver. Settled=false will delay settlement until a disposition has been received. A disposition will be notified to the sender by a message of the following stucture: {amqp10_disposition, {accepted | rejected, DeliveryTag}}
settled(Amqp10_msg::amqp10_msg()) -> boolean()
to_amqp_records(Amqp10_msg::amqp10_msg()) -> [amqp10_client_types:amqp10_msg_record()]
Generated by EDoc