Module rabbit_framing_amqp_0_9_1

Data Types

amqp_array()

amqp_array() = [{amqp_field_type(), amqp_value()}]

amqp_class_id()

amqp_class_id() = 40 | 10 | 50 | 20 | 85 | 90 | 60 | 30

amqp_class_name()

amqp_class_name() = basic | connection | channel | access | exchange | queue | tx | confirm

amqp_exception()

amqp_exception() = frame_method | frame_header | frame_body | frame_heartbeat | frame_min_size | frame_end | reply_success | content_too_large | no_route | no_consumers | access_refused | not_found | resource_locked | precondition_failed | connection_forced | invalid_path | frame_error | syntax_error | command_invalid | channel_error | unexpected_frame | resource_error | not_allowed | not_implemented | internal_error

amqp_exception_code()

amqp_exception_code() = 1 | 2 | 3 | 8 | 4096 | 206 | 200 | 311 | 312 | 313 | 403 | 404 | 405 | 406 | 320 | 402 | 501 | 502 | 503 | 504 | 505 | 506 | 530 | 540 | 541

amqp_field_type()

amqp_field_type() = longstr | signedint | decimal | timestamp | unsignedbyte | unsignedshort | unsignedint | table | byte | double | float | long | short | bool | binary | void | array

amqp_method()

amqp_method() = {60, 10} | {60, 11} | {60, 20} | {60, 21} | {60, 30} | {60, 31} | {60, 40} | {60, 50} | {60, 60} | {60, 70} | {60, 71} | {60, 72} | {60, 80} | {60, 90} | {60, 100} | {60, 110} | {60, 111} | {60, 120} | {60, 200} | {60, 201} | {60, 202} | {10, 10} | {10, 11} | {10, 20} | {10, 21} | {10, 30} | {10, 31} | {10, 40} | {10, 41} | {10, 50} | {10, 51} | {10, 60} | {10, 61} | {10, 70} | {10, 71} | {20, 10} | {20, 11} | {20, 20} | {20, 21} | {20, 40} | {20, 41} | {30, 10} | {30, 11} | {40, 10} | {40, 11} | {40, 20} | {40, 21} | {40, 30} | {40, 31} | {40, 40} | {40, 51} | {50, 10} | {50, 11} | {50, 20} | {50, 21} | {50, 30} | {50, 31} | {50, 40} | {50, 41} | {50, 50} | {50, 51} | {90, 10} | {90, 11} | {90, 20} | {90, 21} | {90, 30} | {90, 31} | {85, 10} | {85, 11}

amqp_method_field_name()

amqp_method_field_name() = active | arguments | auto_delete | available | capabilities | challenge | channel_id | channel_max | class_id | client_properties | cluster_id | consumer_count | consumer_tag | credit | credit_drained | delivery_tag | destination | drain | durable | exchange | exclusive | frame_max | global | heartbeat | if_empty | if_unused | immediate | insist | internal | known_hosts | locale | locales | mandatory | mechanism | mechanisms | message_count | method_id | multiple | new_secret | no_ack | no_local | nowait | out_of_band | passive | prefetch_count | prefetch_size | queue | read | realm | reason | redelivered | reply_code | reply_text | requeue | response | routing_key | server_properties | source | ticket | type | version_major | version_minor | virtual_host | write

amqp_method_name()

amqp_method_name() = 'basic.qos' | 'basic.qos_ok' | 'basic.consume' | 'basic.consume_ok' | 'basic.cancel' | 'basic.cancel_ok' | 'basic.publish' | 'basic.return' | 'basic.deliver' | 'basic.get' | 'basic.get_ok' | 'basic.get_empty' | 'basic.ack' | 'basic.reject' | 'basic.recover_async' | 'basic.recover' | 'basic.recover_ok' | 'basic.nack' | 'basic.credit' | 'basic.credit_ok' | 'basic.credit_drained' | 'connection.start' | 'connection.start_ok' | 'connection.secure' | 'connection.secure_ok' | 'connection.tune' | 'connection.tune_ok' | 'connection.open' | 'connection.open_ok' | 'connection.close' | 'connection.close_ok' | 'connection.blocked' | 'connection.unblocked' | 'connection.update_secret' | 'connection.update_secret_ok' | 'channel.open' | 'channel.open_ok' | 'channel.flow' | 'channel.flow_ok' | 'channel.close' | 'channel.close_ok' | 'access.request' | 'access.request_ok' | 'exchange.declare' | 'exchange.declare_ok' | 'exchange.delete' | 'exchange.delete_ok' | 'exchange.bind' | 'exchange.bind_ok' | 'exchange.unbind' | 'exchange.unbind_ok' | 'queue.declare' | 'queue.declare_ok' | 'queue.bind' | 'queue.bind_ok' | 'queue.purge' | 'queue.purge_ok' | 'queue.delete' | 'queue.delete_ok' | 'queue.unbind' | 'queue.unbind_ok' | 'tx.select' | 'tx.select_ok' | 'tx.commit' | 'tx.commit_ok' | 'tx.rollback' | 'tx.rollback_ok' | 'confirm.select' | 'confirm.select_ok'

amqp_method_record()

amqp_method_record() = #'basic.qos'{} | #'basic.qos_ok'{} | #'basic.consume'{} | #'basic.consume_ok'{} | #'basic.cancel'{} | #'basic.cancel_ok'{} | #'basic.publish'{} | #'basic.return'{} | #'basic.deliver'{} | #'basic.get'{} | #'basic.get_ok'{} | #'basic.get_empty'{} | #'basic.ack'{} | #'basic.reject'{} | #'basic.recover_async'{} | #'basic.recover'{} | #'basic.recover_ok'{} | #'basic.nack'{} | #'basic.credit'{} | #'basic.credit_ok'{} | #'basic.credit_drained'{} | #'connection.start'{} | #'connection.start_ok'{} | #'connection.secure'{} | #'connection.secure_ok'{} | #'connection.tune'{} | #'connection.tune_ok'{} | #'connection.open'{} | #'connection.open_ok'{} | #'connection.close'{} | #'connection.close_ok'{} | #'connection.blocked'{} | #'connection.unblocked'{} | #'connection.update_secret'{} | #'connection.update_secret_ok'{} | #'channel.open'{} | #'channel.open_ok'{} | #'channel.flow'{} | #'channel.flow_ok'{} | #'channel.close'{} | #'channel.close_ok'{} | #'access.request'{} | #'access.request_ok'{} | #'exchange.declare'{} | #'exchange.declare_ok'{} | #'exchange.delete'{} | #'exchange.delete_ok'{} | #'exchange.bind'{} | #'exchange.bind_ok'{} | #'exchange.unbind'{} | #'exchange.unbind_ok'{} | #'queue.declare'{} | #'queue.declare_ok'{} | #'queue.bind'{} | #'queue.bind_ok'{} | #'queue.purge'{} | #'queue.purge_ok'{} | #'queue.delete'{} | #'queue.delete_ok'{} | #'queue.unbind'{} | #'queue.unbind_ok'{} | #'tx.select'{} | #'tx.select_ok'{} | #'tx.commit'{} | #'tx.commit_ok'{} | #'tx.rollback'{} | #'tx.rollback_ok'{} | #'confirm.select'{} | #'confirm.select_ok'{}

amqp_property_record()

amqp_property_record() = #'P_basic'{} | #'P_connection'{} | #'P_channel'{} | #'P_access'{} | #'P_exchange'{} | #'P_queue'{} | #'P_tx'{} | #'P_confirm'{}

amqp_property_type()

amqp_property_type() = shortstr | longstr | octet | short | long | longlong | timestamp | bit | table

amqp_table()

amqp_table() = [{binary(), amqp_field_type(), amqp_value()}]

amqp_value()

amqp_value() = binary() | integer() | {non_neg_integer(), non_neg_integer()} | amqp_table() | amqp_array() | byte() | float() | integer() | integer() | boolean() | binary() | undefined | non_neg_integer()

Function Index

amqp_exception/1
decode_method_fields/2
decode_properties/2
encode_method_fields/1
encode_properties/1
is_method_synchronous/1
lookup_amqp_exception/1
lookup_class_name/1
lookup_method_name/1
method_fieldnames/1
method_has_content/1
method_id/1
method_record/1
version/0

Function Details

amqp_exception/1

amqp_exception(Code::amqp_exception_code()) -> amqp_exception()

decode_method_fields/2

decode_method_fields(Name::amqp_method_name(), BinaryFields::binary()) -> amqp_method_record() | rabbit_types:connection_exit()

decode_properties/2

decode_properties(ClassId::non_neg_integer(), BinaryFields::binary()) -> amqp_property_record()

encode_method_fields/1

encode_method_fields(Record::amqp_method_record()) -> binary()

encode_properties/1

encode_properties(Record::amqp_property_record()) -> binary()

is_method_synchronous/1

is_method_synchronous(Name::amqp_method_record()) -> boolean()

lookup_amqp_exception/1

lookup_amqp_exception(Code::amqp_exception()) -> {boolean(), amqp_exception_code(), binary()}

lookup_class_name/1

lookup_class_name(ClassId::amqp_class_id()) -> amqp_class_name()

lookup_method_name/1

lookup_method_name(Id::amqp_method()) -> amqp_method_name()

method_fieldnames/1

method_fieldnames(Name::amqp_method_name()) -> [amqp_method_field_name()]

method_has_content/1

method_has_content(Name::amqp_method_name()) -> boolean()

method_id/1

method_id(Name::amqp_method_name()) -> amqp_method()

method_record/1

method_record(Name::amqp_method_name()) -> amqp_method_record()

version/0

version() -> {non_neg_integer(), non_neg_integer(), non_neg_integer()}


Generated by EDoc