Module rabbit_framing_amqp_0_8

Data Types

amqp_array()

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

amqp_class_id()

amqp_class_id() = 100 | 70 | 40 | 10 | 110 | 80 | 50 | 20 | 120 | 90 | 60 | 30

amqp_class_name()

amqp_class_name() = connection | channel | access | exchange | queue | basic | file | stream | tx | dtx | tunnel | test

amqp_exception()

amqp_exception() = frame_method | frame_header | frame_body | frame_oob_method | frame_oob_header | frame_oob_body | frame_trace | frame_heartbeat | frame_min_size | frame_end | reply_success | not_delivered | 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 | 4 | 5 | 6 | 7 | 8 | 4096 | 206 | 200 | 310 | 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() = {10, 10} | {10, 11} | {10, 20} | {10, 21} | {10, 30} | {10, 31} | {10, 40} | {10, 41} | {10, 50} | {10, 60} | {10, 61} | {20, 10} | {20, 11} | {20, 20} | {20, 21} | {20, 30} | {20, 40} | {20, 41} | {30, 10} | {30, 11} | {40, 10} | {40, 11} | {40, 20} | {40, 21} | {50, 10} | {50, 11} | {50, 20} | {50, 21} | {50, 30} | {50, 31} | {50, 40} | {50, 41} | {50, 50} | {50, 51} | {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} | {70, 10} | {70, 11} | {70, 20} | {70, 21} | {70, 30} | {70, 31} | {70, 40} | {70, 41} | {70, 50} | {70, 60} | {70, 70} | {70, 80} | {70, 90} | {70, 100} | {80, 10} | {80, 11} | {80, 20} | {80, 21} | {80, 30} | {80, 31} | {80, 40} | {80, 50} | {80, 60} | {90, 10} | {90, 11} | {90, 20} | {90, 21} | {90, 30} | {90, 31} | {100, 10} | {100, 11} | {100, 20} | {100, 21} | {110, 10} | {120, 10} | {120, 11} | {120, 20} | {120, 21} | {120, 30} | {120, 31} | {120, 40} | {120, 41}

amqp_method_field_name()

amqp_method_field_name() = active | arguments | auto_delete | capabilities | challenge | channel_max | class_id | client_properties | cluster_id | consume_rate | consumer_count | consumer_tag | content_checksum | content_size | delivery_tag | details | dtx_identifier | durable | exchange | exclusive | frame_max | global | heartbeat | host | identifier | if_empty | if_unused | immediate | insist | integer_1 | integer_2 | integer_3 | integer_4 | integer_op | integer_result | internal | known_hosts | locale | locales | mandatory | mechanism | mechanisms | message_count | meta_data | method_id | multiple | no_ack | no_local | nowait | operation | out_of_band | passive | prefetch_count | prefetch_size | queue | read | realm | redelivered | reply_code | reply_text | requeue | response | result | routing_key | server_properties | staged_size | string_1 | string_2 | string_op | string_result | table | ticket | type | version_major | version_minor | virtual_host | write

amqp_method_name()

amqp_method_name() = 'connection.start' | 'connection.start_ok' | 'connection.secure' | 'connection.secure_ok' | 'connection.tune' | 'connection.tune_ok' | 'connection.open' | 'connection.open_ok' | 'connection.redirect' | 'connection.close' | 'connection.close_ok' | 'channel.open' | 'channel.open_ok' | 'channel.flow' | 'channel.flow_ok' | 'channel.alert' | 'channel.close' | 'channel.close_ok' | 'access.request' | 'access.request_ok' | 'exchange.declare' | 'exchange.declare_ok' | 'exchange.delete' | 'exchange.delete_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' | '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' | 'file.qos' | 'file.qos_ok' | 'file.consume' | 'file.consume_ok' | 'file.cancel' | 'file.cancel_ok' | 'file.open' | 'file.open_ok' | 'file.stage' | 'file.publish' | 'file.return' | 'file.deliver' | 'file.ack' | 'file.reject' | 'stream.qos' | 'stream.qos_ok' | 'stream.consume' | 'stream.consume_ok' | 'stream.cancel' | 'stream.cancel_ok' | 'stream.publish' | 'stream.return' | 'stream.deliver' | 'tx.select' | 'tx.select_ok' | 'tx.commit' | 'tx.commit_ok' | 'tx.rollback' | 'tx.rollback_ok' | 'dtx.select' | 'dtx.select_ok' | 'dtx.start' | 'dtx.start_ok' | 'tunnel.request' | 'test.integer' | 'test.integer_ok' | 'test.string' | 'test.string_ok' | 'test.table' | 'test.table_ok' | 'test.content' | 'test.content_ok'

amqp_method_record()

amqp_method_record() = #'connection.start'{} | #'connection.start_ok'{} | #'connection.secure'{} | #'connection.secure_ok'{} | #'connection.tune'{} | #'connection.tune_ok'{} | #'connection.open'{} | #'connection.open_ok'{} | #'connection.redirect'{} | #'connection.close'{} | #'connection.close_ok'{} | #'channel.open'{} | #'channel.open_ok'{} | #'channel.flow'{} | #'channel.flow_ok'{} | #'channel.alert'{} | #'channel.close'{} | #'channel.close_ok'{} | #'access.request'{} | #'access.request_ok'{} | #'exchange.declare'{} | #'exchange.declare_ok'{} | #'exchange.delete'{} | #'exchange.delete_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'{} | #'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'{} | #'file.qos'{} | #'file.qos_ok'{} | #'file.consume'{} | #'file.consume_ok'{} | #'file.cancel'{} | #'file.cancel_ok'{} | #'file.open'{} | #'file.open_ok'{} | #'file.stage'{} | #'file.publish'{} | #'file.return'{} | #'file.deliver'{} | #'file.ack'{} | #'file.reject'{} | #'stream.qos'{} | #'stream.qos_ok'{} | #'stream.consume'{} | #'stream.consume_ok'{} | #'stream.cancel'{} | #'stream.cancel_ok'{} | #'stream.publish'{} | #'stream.return'{} | #'stream.deliver'{} | #'tx.select'{} | #'tx.select_ok'{} | #'tx.commit'{} | #'tx.commit_ok'{} | #'tx.rollback'{} | #'tx.rollback_ok'{} | #'dtx.select'{} | #'dtx.select_ok'{} | #'dtx.start'{} | #'dtx.start_ok'{} | #'tunnel.request'{} | #'test.integer'{} | #'test.integer_ok'{} | #'test.string'{} | #'test.string_ok'{} | #'test.table'{} | #'test.table_ok'{} | #'test.content'{} | #'test.content_ok'{}

amqp_property_record()

amqp_property_record() = #'P_connection'{} | #'P_channel'{} | #'P_access'{} | #'P_exchange'{} | #'P_queue'{} | #'P_basic'{} | #'P_file'{} | #'P_stream'{} | #'P_tx'{} | #'P_dtx'{} | #'P_tunnel'{} | #'P_test'{}

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