| Overview |  |
amqp10_event() = {amqp10_event, amqp10_event_detail()}
amqp10_event_detail() = {connection, pid(), connection_event_detail()} | {session, pid(), session_event_detail()} | {link, {sender | receiver, Name::binary()}, link_event_detail()}
amqp10_msg_record() = #'v1_0.transfer'{} | #'v1_0.header'{} | #'v1_0.delivery_annotations'{} | #'v1_0.message_annotations'{} | #'v1_0.properties'{} | #'v1_0.application_properties'{} | #'v1_0.data'{} | #'v1_0.amqp_sequence'{} | #'v1_0.amqp_value'{} | #'v1_0.footer'{}
amqp10_performative() = #'v1_0.open'{} | #'v1_0.begin'{} | #'v1_0.attach'{} | #'v1_0.flow'{} | #'v1_0.transfer'{} | #'v1_0.disposition'{} | #'v1_0.detach'{} | #'v1_0.end'{} | #'v1_0.close'{}
amqp_error() = internal_error | not_found | unauthorized_access | decode_error | resource_limit_exceeded | not_allowed | invalid_field | not_implemented | resource_locked | precondition_failed | resource_deleted | illegal_state | frame_size_too_small
channel() = non_neg_integer()
connection_error() = connection_forced | framing_error | redirect
connection_event_detail() = opened | {closed, Reason::any()} | {error, {connection_error(), any()}}
delivery_state() = accepted | rejected | modified | {modified, DeliveryFailed::boolean(), UndeliverableHere::boolean(), MessageAnnotations::#{amqp10_msg:annotations_key() => term()}} | received | released
link_error() = atom()
TODO
link_event_detail() = attached | detached | {error, {link_error(), any()}}
properties() = #{binary() => amqp10_binary_generator:amqp10_prim()}
session_error() = atom()
TODO
session_event_detail() = begun | ended | {error, {session_error(), any()}}
source() = #'v1_0.source'{}
target() = #'v1_0.target'{}
| make_properties/1 | |
| uint/1 | |
| unpack/1 | |
| utf8/1 |
make_properties(X1) -> any()
uint(N) -> any()
unpack(Value) -> any()
utf8(S) -> any()
Generated by EDoc