diff options
author | Ronnie Sahlberg <ronnie_sahlberg@ozemail.com.au> | 2007-03-26 01:34:06 +0000 |
---|---|---|
committer | Ronnie Sahlberg <ronnie_sahlberg@ozemail.com.au> | 2007-03-26 01:34:06 +0000 |
commit | d3283d23eaa8ef519fe450f7b72deaf9fac2a108 (patch) | |
tree | 6bbf972d15ec67a6b1e1029226a2971e6f11bf5b | |
parent | d14c5ba107f365708118121ad1c7053f3979efeb (diff) |
From
Martin Sustrik
additions to AMQP dissector and prettifications to the information column
svn path=/trunk/; revision=21196
-rwxr-xr-x | epan/dissectors/packet-amqp.c | 1869 |
1 files changed, 1001 insertions, 868 deletions
diff --git a/epan/dissectors/packet-amqp.c b/epan/dissectors/packet-amqp.c index 37fd393e0a..5e72203aec 100755 --- a/epan/dissectors/packet-amqp.c +++ b/epan/dissectors/packet-amqp.c @@ -1,6 +1,6 @@ /* packet-amqp.c * - * AMQP Wireshark dissector + * AMQP v0-9 Wireshark dissector plug-in * * Author: Martin Sustrik <sustrik@imatix.com> * @@ -71,7 +71,6 @@ static int amqp_port = 5672; #define AMQP_CLASS_TX 90 #define AMQP_CLASS_DTX 100 #define AMQP_CLASS_TUNNEL 110 -#define AMQP_CLASS_TEST 120 #define AMQP_METHOD_CONNECTION_START 10 #define AMQP_METHOD_CONNECTION_START_OK 11 @@ -81,17 +80,20 @@ static int amqp_port = 5672; #define AMQP_METHOD_CONNECTION_TUNE_OK 31 #define AMQP_METHOD_CONNECTION_OPEN 40 #define AMQP_METHOD_CONNECTION_OPEN_OK 41 -#define AMQP_METHOD_CONNECTION_REDIRECT 50 -#define AMQP_METHOD_CONNECTION_CLOSE 60 -#define AMQP_METHOD_CONNECTION_CLOSE_OK 61 +#define AMQP_METHOD_CONNECTION_REDIRECT 42 +#define AMQP_METHOD_CONNECTION_CLOSE 50 +#define AMQP_METHOD_CONNECTION_CLOSE_OK 51 #define AMQP_METHOD_CHANNEL_OPEN 10 #define AMQP_METHOD_CHANNEL_OPEN_OK 11 #define AMQP_METHOD_CHANNEL_FLOW 20 #define AMQP_METHOD_CHANNEL_FLOW_OK 21 -#define AMQP_METHOD_CHANNEL_ALERT 30 #define AMQP_METHOD_CHANNEL_CLOSE 40 #define AMQP_METHOD_CHANNEL_CLOSE_OK 41 +#define AMQP_METHOD_CHANNEL_RESUME 50 +#define AMQP_METHOD_CHANNEL_PING 60 +#define AMQP_METHOD_CHANNEL_PONG 70 +#define AMQP_METHOD_CHANNEL_OK 80 #define AMQP_METHOD_ACCESS_REQUEST 10 #define AMQP_METHOD_ACCESS_REQUEST_OK 11 @@ -105,6 +107,8 @@ static int amqp_port = 5672; #define AMQP_METHOD_QUEUE_DECLARE_OK 11 #define AMQP_METHOD_QUEUE_BIND 20 #define AMQP_METHOD_QUEUE_BIND_OK 21 +#define AMQP_METHOD_QUEUE_UNBIND 50 +#define AMQP_METHOD_QUEUE_UNBIND_OK 51 #define AMQP_METHOD_QUEUE_PURGE 30 #define AMQP_METHOD_QUEUE_PURGE_OK 31 #define AMQP_METHOD_QUEUE_DELETE 40 @@ -165,15 +169,6 @@ static int amqp_port = 5672; #define AMQP_METHOD_TUNNEL_REQUEST 10 -#define AMQP_METHOD_TEST_INTEGER 10 -#define AMQP_METHOD_TEST_INTEGER_OK 11 -#define AMQP_METHOD_TEST_STRING 20 -#define AMQP_METHOD_TEST_STRING_OK 21 -#define AMQP_METHOD_TEST_TABLE 30 -#define AMQP_METHOD_TEST_TABLE_OK 31 -#define AMQP_METHOD_TEST_CONTENT 40 -#define AMQP_METHOD_TEST_CONTENT_OK 41 - /* Registration functions for the dissector */ void @@ -257,15 +252,27 @@ dissect_amqp_method_channel_flow_ok(tvbuff_t *tvb, int offset, int bound, proto_tree *args_tree); static size_t -dissect_amqp_method_channel_alert(tvbuff_t *tvb, +dissect_amqp_method_channel_close(tvbuff_t *tvb, int offset, int bound, proto_tree *args_tree); static size_t -dissect_amqp_method_channel_close(tvbuff_t *tvb, +dissect_amqp_method_channel_close_ok(tvbuff_t *tvb, int offset, int bound, proto_tree *args_tree); static size_t -dissect_amqp_method_channel_close_ok(tvbuff_t *tvb, +dissect_amqp_method_channel_resume(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree); + +static size_t +dissect_amqp_method_channel_ping(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree); + +static size_t +dissect_amqp_method_channel_pong(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree); + +static size_t +dissect_amqp_method_channel_ok(tvbuff_t *tvb, int offset, int bound, proto_tree *args_tree); static size_t @@ -309,6 +316,14 @@ dissect_amqp_method_queue_bind_ok(tvbuff_t *tvb, int offset, int bound, proto_tree *args_tree); static size_t +dissect_amqp_method_queue_unbind(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree); + +static size_t +dissect_amqp_method_queue_unbind_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree); + +static size_t dissect_amqp_method_queue_purge(tvbuff_t *tvb, int offset, int bound, proto_tree *args_tree); @@ -521,38 +536,6 @@ dissect_amqp_method_tunnel_request(tvbuff_t *tvb, int offset, int bound, proto_tree *args_tree); static size_t -dissect_amqp_method_test_integer(tvbuff_t *tvb, - int offset, int bound, proto_tree *args_tree); - -static size_t -dissect_amqp_method_test_integer_ok(tvbuff_t *tvb, - int offset, int bound, proto_tree *args_tree); - -static size_t -dissect_amqp_method_test_string(tvbuff_t *tvb, - int offset, int bound, proto_tree *args_tree); - -static size_t -dissect_amqp_method_test_string_ok(tvbuff_t *tvb, - int offset, int bound, proto_tree *args_tree); - -static size_t -dissect_amqp_method_test_table(tvbuff_t *tvb, - int offset, int bound, proto_tree *args_tree); - -static size_t -dissect_amqp_method_test_table_ok(tvbuff_t *tvb, - int offset, int bound, proto_tree *args_tree); - -static size_t -dissect_amqp_method_test_content(tvbuff_t *tvb, - int offset, int bound, proto_tree *args_tree); - -static size_t -dissect_amqp_method_test_content_ok(tvbuff_t *tvb, - int offset, int bound, proto_tree *args_tree); - -static size_t dissect_amqp_content_header_basic(tvbuff_t *tvb, int offset, int bound, proto_tree *prop_tree); @@ -587,7 +570,6 @@ static int hf_amqp_method_stream_method_id = -1; static int hf_amqp_method_tx_method_id = -1; static int hf_amqp_method_dtx_method_id = -1; static int hf_amqp_method_tunnel_method_id = -1; -static int hf_amqp_method_test_method_id = -1; static int hf_amqp_method_arguments = -1; static int hf_amqp_method_connection_start_version_major = -1; static int hf_amqp_method_connection_start_version_minor = -1; @@ -617,15 +599,14 @@ static int hf_amqp_method_connection_close_reply_text = -1; static int hf_amqp_method_connection_close_class_id = -1; static int hf_amqp_method_connection_close_method_id = -1; static int hf_amqp_method_channel_open_out_of_band = -1; +static int hf_amqp_method_channel_open_ok_channel_id = -1; static int hf_amqp_method_channel_flow_active = -1; static int hf_amqp_method_channel_flow_ok_active = -1; -static int hf_amqp_method_channel_alert_reply_code = -1; -static int hf_amqp_method_channel_alert_reply_text = -1; -static int hf_amqp_method_channel_alert_details = -1; static int hf_amqp_method_channel_close_reply_code = -1; static int hf_amqp_method_channel_close_reply_text = -1; static int hf_amqp_method_channel_close_class_id = -1; static int hf_amqp_method_channel_close_method_id = -1; +static int hf_amqp_method_channel_resume_channel_id = -1; static int hf_amqp_method_access_request_realm = -1; static int hf_amqp_method_access_request_exclusive = -1; static int hf_amqp_method_access_request_passive = -1; @@ -663,6 +644,11 @@ static int hf_amqp_method_queue_bind_exchange = -1; static int hf_amqp_method_queue_bind_routing_key = -1; static int hf_amqp_method_queue_bind_nowait = -1; static int hf_amqp_method_queue_bind_arguments = -1; +static int hf_amqp_method_queue_unbind_ticket = -1; +static int hf_amqp_method_queue_unbind_queue = -1; +static int hf_amqp_method_queue_unbind_exchange = -1; +static int hf_amqp_method_queue_unbind_routing_key = -1; +static int hf_amqp_method_queue_unbind_arguments = -1; static int hf_amqp_method_queue_purge_ticket = -1; static int hf_amqp_method_queue_purge_queue = -1; static int hf_amqp_method_queue_purge_nowait = -1; @@ -683,6 +669,7 @@ static int hf_amqp_method_basic_consume_no_local = -1; static int hf_amqp_method_basic_consume_no_ack = -1; static int hf_amqp_method_basic_consume_exclusive = -1; static int hf_amqp_method_basic_consume_nowait = -1; +static int hf_amqp_method_basic_consume_filter = -1; static int hf_amqp_method_basic_consume_ok_consumer_tag = -1; static int hf_amqp_method_basic_cancel_consumer_tag = -1; static int hf_amqp_method_basic_cancel_nowait = -1; @@ -725,6 +712,7 @@ static int hf_amqp_method_file_consume_no_local = -1; static int hf_amqp_method_file_consume_no_ack = -1; static int hf_amqp_method_file_consume_exclusive = -1; static int hf_amqp_method_file_consume_nowait = -1; +static int hf_amqp_method_file_consume_filter = -1; static int hf_amqp_method_file_consume_ok_consumer_tag = -1; static int hf_amqp_method_file_cancel_consumer_tag = -1; static int hf_amqp_method_file_cancel_nowait = -1; @@ -762,6 +750,7 @@ static int hf_amqp_method_stream_consume_consumer_tag = -1; static int hf_amqp_method_stream_consume_no_local = -1; static int hf_amqp_method_stream_consume_exclusive = -1; static int hf_amqp_method_stream_consume_nowait = -1; +static int hf_amqp_method_stream_consume_filter = -1; static int hf_amqp_method_stream_consume_ok_consumer_tag = -1; static int hf_amqp_method_stream_cancel_consumer_tag = -1; static int hf_amqp_method_stream_cancel_nowait = -1; @@ -781,22 +770,6 @@ static int hf_amqp_method_stream_deliver_exchange = -1; static int hf_amqp_method_stream_deliver_queue = -1; static int hf_amqp_method_dtx_start_dtx_identifier = -1; static int hf_amqp_method_tunnel_request_meta_data = -1; -static int hf_amqp_method_test_integer_integer_1 = -1; -static int hf_amqp_method_test_integer_integer_2 = -1; -static int hf_amqp_method_test_integer_integer_3 = -1; -static int hf_amqp_method_test_integer_integer_4 = -1; -static int hf_amqp_method_test_integer_operation = -1; -static int hf_amqp_method_test_integer_ok_result = -1; -static int hf_amqp_method_test_string_string_1 = -1; -static int hf_amqp_method_test_string_string_2 = -1; -static int hf_amqp_method_test_string_operation = -1; -static int hf_amqp_method_test_string_ok_result = -1; -static int hf_amqp_method_test_table_table = -1; -static int hf_amqp_method_test_table_integer_op = -1; -static int hf_amqp_method_test_table_string_op = -1; -static int hf_amqp_method_test_table_ok_integer_result = -1; -static int hf_amqp_method_test_table_ok_string_result = -1; -static int hf_amqp_method_test_content_ok_content_checksum = -1; static int hf_amqp_field = -1; static int hf_amqp_header_class_id = -1; static int hf_amqp_header_weight = -1; @@ -837,11 +810,17 @@ static int hf_amqp_header_tunnel_data_name = -1; static int hf_amqp_header_tunnel_durable = -1; static int hf_amqp_header_tunnel_broadcast = -1; static int hf_amqp_payload = -1; +static int hf_amqp_init_protocol = -1; +static int hf_amqp_init_id_major = -1; +static int hf_amqp_init_id_minor = -1; +static int hf_amqp_init_version_major = -1; +static int hf_amqp_init_version_minor = -1; static gint ett_amqp = -1; static gint ett_args = -1; static gint ett_props = -1; static gint ett_field_table = -1; +static gint ett_amqp_init = -1; /* Various enumerations */ @@ -869,7 +848,6 @@ static const value_string amqp_method_classes [] = { {90, "Tx"}, {100, "Dtx"}, {110, "Tunnel"}, - {120, "Test"}, {0, NULL} }; @@ -882,9 +860,9 @@ static const value_string amqp_method_connection_methods [] = { {31, "Tune-Ok"}, {40, "Open"}, {41, "Open-Ok"}, - {50, "Redirect"}, - {60, "Close"}, - {61, "Close-Ok"}, + {42, "Redirect"}, + {50, "Close"}, + {51, "Close-Ok"}, {0, NULL} }; @@ -893,9 +871,12 @@ static const value_string amqp_method_channel_methods [] = { {11, "Open-Ok"}, {20, "Flow"}, {21, "Flow-Ok"}, - {30, "Alert"}, {40, "Close"}, {41, "Close-Ok"}, + {50, "Resume"}, + {60, "Ping"}, + {70, "Pong"}, + {80, "Ok"}, {0, NULL} }; @@ -918,6 +899,8 @@ static const value_string amqp_method_queue_methods [] = { {11, "Declare-Ok"}, {20, "Bind"}, {21, "Bind-Ok"}, + {50, "Unbind"}, + {51, "Unbind-Ok"}, {30, "Purge"}, {31, "Purge-Ok"}, {40, "Delete"}, @@ -998,23 +981,14 @@ static const value_string amqp_method_tunnel_methods [] = { {0, NULL} }; -static const value_string amqp_method_test_methods [] = { - {10, "Integer"}, - {11, "Integer-Ok"}, - {20, "String"}, - {21, "String-Ok"}, - {30, "Table"}, - {31, "Table-Ok"}, - {40, "Content"}, - {41, "Content-Ok"}, - {0, NULL} -}; - /* Main dissection routine */ static void dissect_amqp(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) { + /* Minimal frame size is 8 bytes - smaller frames are malformed */ + DISSECTOR_ASSERT (tvb_length (tvb) >= 8); + tcp_dissect_pdus(tvb, pinfo, tree, TRUE, 7, get_amqp_message_len, dissect_amqp_frame); } @@ -1022,6 +996,13 @@ dissect_amqp(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) static guint get_amqp_message_len(packet_info *pinfo _U_, tvbuff_t *tvb, int offset) { + /* Heuristic - protocol initialisation frame starts with 'AMQP' */ + if (tvb_get_guint8(tvb, 0) == 'A' && + tvb_get_guint8(tvb, 1) == 'M' && + tvb_get_guint8(tvb, 2) == 'Q' && + tvb_get_guint8(tvb, 3) == 'P') + return 8; + return (guint) tvb_get_ntohl(tvb, offset + 3) + 8; } @@ -1119,8 +1100,6 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) proto_item *prop_tree; size_t length; int offset; - guint8 type; - guint16 channel, method, class; if (check_col(pinfo->cinfo, COL_PROTOCOL)) col_set_str(pinfo->cinfo, COL_PROTOCOL, "AMQP"); @@ -1129,46 +1108,41 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) } if (tree) { + + /* Heuristic - protocol initialisation frame starts with 'AMQP' */ + if (tvb_get_guint8(tvb, 0) == 'A' && + tvb_get_guint8(tvb, 1) == 'M' && + tvb_get_guint8(tvb, 2) == 'Q' && + tvb_get_guint8(tvb, 3) == 'P') { + + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, "Protocol header"); + + ti = proto_tree_add_item(tree, proto_amqp, tvb, 0, -1, FALSE); + amqp_tree = proto_item_add_subtree(ti, ett_amqp_init); + proto_tree_add_item(amqp_tree, hf_amqp_init_protocol, tvb, 0, 4, FALSE); + proto_tree_add_item(amqp_tree, hf_amqp_init_id_major, tvb, 4, 1, FALSE); + proto_tree_add_item(amqp_tree, hf_amqp_init_id_minor, tvb, 5, 1, FALSE); + proto_tree_add_item(amqp_tree, hf_amqp_init_version_major, tvb, 6, 1, FALSE); + proto_tree_add_item(amqp_tree, hf_amqp_init_version_minor, tvb, 7, 1, FALSE); + + return; + } ti = proto_tree_add_item(tree, proto_amqp, tvb, 0, -1, FALSE); amqp_tree = proto_item_add_subtree(ti, ett_amqp); - - proto_tree_add_item(amqp_tree, hf_amqp_type, tvb, 0, 1, FALSE); - type=tvb_get_guint8(tvb, 0); - if (check_col(pinfo->cinfo, COL_INFO)) { - col_append_fstr(pinfo->cinfo, COL_INFO, "%s/", - val_to_str(type, amqp_frame_types, "Unknown method:%u")); - } - - proto_tree_add_item(amqp_tree, hf_amqp_channel, tvb, 1, 2, FALSE); - channel=tvb_get_ntohs(tvb, 1); - if (check_col(pinfo->cinfo, COL_INFO)) { - col_append_fstr(pinfo->cinfo, COL_INFO, "%d/", - channel); - } - - proto_tree_add_item(amqp_tree, hf_amqp_length, tvb, 3, 4, FALSE); + proto_tree_add_item(amqp_tree, hf_amqp_type, tvb, 0, 1, FALSE); + proto_tree_add_item(amqp_tree, hf_amqp_channel, tvb, 1, 2, FALSE); + proto_tree_add_item(amqp_tree, hf_amqp_length, tvb, 3, 4, FALSE); length = tvb_get_ntohl(tvb, 3); switch (tvb_get_guint8(tvb, 0)) { case AMQP_FRAME_TYPE_METHOD: proto_tree_add_item(amqp_tree, hf_amqp_method_class_id, tvb, 7, 2, FALSE); - class=tvb_get_ntohs(tvb, 7); - if (check_col(pinfo->cinfo, COL_INFO)) { - col_append_fstr(pinfo->cinfo, COL_INFO, "%s/", - val_to_str(class, amqp_method_classes, "Unknown class:%u")); - } - switch (tvb_get_ntohs(tvb, 7)) { case AMQP_CLASS_CONNECTION: proto_tree_add_item(amqp_tree, hf_amqp_method_connection_method_id, tvb, 9, 2, FALSE); - method=tvb_get_ntohs(tvb, 9); - if (check_col(pinfo->cinfo, COL_INFO)) { - col_append_fstr(pinfo->cinfo, COL_INFO, "%s ", - val_to_str(method, amqp_method_connection_methods, "unknown method:%x")); - } - ti = proto_tree_add_item(amqp_tree, hf_amqp_method_arguments, tvb, 11, length - 4, FALSE); args_tree = proto_item_add_subtree(ti, ett_args); @@ -1176,46 +1150,79 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_CONNECTION_START: offset = dissect_amqp_method_connection_start(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Start"); break; case AMQP_METHOD_CONNECTION_START_OK: offset = dissect_amqp_method_connection_start_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Start-Ok"); break; case AMQP_METHOD_CONNECTION_SECURE: offset = dissect_amqp_method_connection_secure(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Secure"); break; case AMQP_METHOD_CONNECTION_SECURE_OK: offset = dissect_amqp_method_connection_secure_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Secure-Ok"); break; case AMQP_METHOD_CONNECTION_TUNE: offset = dissect_amqp_method_connection_tune(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Tune"); break; case AMQP_METHOD_CONNECTION_TUNE_OK: offset = dissect_amqp_method_connection_tune_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Tune-Ok"); break; case AMQP_METHOD_CONNECTION_OPEN: offset = dissect_amqp_method_connection_open(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Open"); break; case AMQP_METHOD_CONNECTION_OPEN_OK: offset = dissect_amqp_method_connection_open_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Open-Ok"); break; case AMQP_METHOD_CONNECTION_REDIRECT: offset = dissect_amqp_method_connection_redirect(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Redirect"); break; case AMQP_METHOD_CONNECTION_CLOSE: offset = dissect_amqp_method_connection_close(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Close"); break; case AMQP_METHOD_CONNECTION_CLOSE_OK: offset = dissect_amqp_method_connection_close_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Connection.Close-Ok"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1231,30 +1238,72 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_CHANNEL_OPEN: offset = dissect_amqp_method_channel_open(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Open"); break; case AMQP_METHOD_CHANNEL_OPEN_OK: offset = dissect_amqp_method_channel_open_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Open-Ok"); break; case AMQP_METHOD_CHANNEL_FLOW: offset = dissect_amqp_method_channel_flow(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Flow"); break; case AMQP_METHOD_CHANNEL_FLOW_OK: offset = dissect_amqp_method_channel_flow_ok(tvb, 11, tvb_length (tvb), args_tree); - break; - case AMQP_METHOD_CHANNEL_ALERT: - offset = dissect_amqp_method_channel_alert(tvb, - 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Flow-Ok"); break; case AMQP_METHOD_CHANNEL_CLOSE: offset = dissect_amqp_method_channel_close(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Close"); break; case AMQP_METHOD_CHANNEL_CLOSE_OK: offset = dissect_amqp_method_channel_close_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Close-Ok"); + break; + case AMQP_METHOD_CHANNEL_RESUME: + offset = dissect_amqp_method_channel_resume(tvb, + 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Resume"); + break; + case AMQP_METHOD_CHANNEL_PING: + offset = dissect_amqp_method_channel_ping(tvb, + 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Ping"); + break; + case AMQP_METHOD_CHANNEL_PONG: + offset = dissect_amqp_method_channel_pong(tvb, + 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Pong"); + break; + case AMQP_METHOD_CHANNEL_OK: + offset = dissect_amqp_method_channel_ok(tvb, + 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Channel.Ok"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1270,10 +1319,16 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_ACCESS_REQUEST: offset = dissect_amqp_method_access_request(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Access.Request"); break; case AMQP_METHOD_ACCESS_REQUEST_OK: offset = dissect_amqp_method_access_request_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Access.Request-Ok"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1289,18 +1344,30 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_EXCHANGE_DECLARE: offset = dissect_amqp_method_exchange_declare(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Exchange.Declare"); break; case AMQP_METHOD_EXCHANGE_DECLARE_OK: offset = dissect_amqp_method_exchange_declare_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Exchange.Declare-Ok"); break; case AMQP_METHOD_EXCHANGE_DELETE: offset = dissect_amqp_method_exchange_delete(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Exchange.Delete"); break; case AMQP_METHOD_EXCHANGE_DELETE_OK: offset = dissect_amqp_method_exchange_delete_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Exchange.Delete-Ok"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1316,34 +1383,72 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_QUEUE_DECLARE: offset = dissect_amqp_method_queue_declare(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Declare"); break; case AMQP_METHOD_QUEUE_DECLARE_OK: offset = dissect_amqp_method_queue_declare_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Declare-Ok"); break; case AMQP_METHOD_QUEUE_BIND: offset = dissect_amqp_method_queue_bind(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Bind"); break; case AMQP_METHOD_QUEUE_BIND_OK: offset = dissect_amqp_method_queue_bind_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Bind-Ok"); + break; + case AMQP_METHOD_QUEUE_UNBIND: + offset = dissect_amqp_method_queue_unbind(tvb, + 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Unbind"); + break; + case AMQP_METHOD_QUEUE_UNBIND_OK: + offset = dissect_amqp_method_queue_unbind_ok(tvb, + 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Unbind-Ok"); break; case AMQP_METHOD_QUEUE_PURGE: offset = dissect_amqp_method_queue_purge(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Purge"); break; case AMQP_METHOD_QUEUE_PURGE_OK: offset = dissect_amqp_method_queue_purge_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Purge-Ok"); break; case AMQP_METHOD_QUEUE_DELETE: offset = dissect_amqp_method_queue_delete(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Delete"); break; case AMQP_METHOD_QUEUE_DELETE_OK: offset = dissect_amqp_method_queue_delete_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Queue.Delete-Ok"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1359,62 +1464,107 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_BASIC_QOS: offset = dissect_amqp_method_basic_qos(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Qos"); break; case AMQP_METHOD_BASIC_QOS_OK: offset = dissect_amqp_method_basic_qos_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Qos-Ok"); break; case AMQP_METHOD_BASIC_CONSUME: offset = dissect_amqp_method_basic_consume(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Consume"); break; case AMQP_METHOD_BASIC_CONSUME_OK: offset = dissect_amqp_method_basic_consume_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Consume-Ok"); break; case AMQP_METHOD_BASIC_CANCEL: offset = dissect_amqp_method_basic_cancel(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Cancel"); break; case AMQP_METHOD_BASIC_CANCEL_OK: offset = dissect_amqp_method_basic_cancel_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Cancel-Ok"); break; case AMQP_METHOD_BASIC_PUBLISH: offset = dissect_amqp_method_basic_publish(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Publish"); break; case AMQP_METHOD_BASIC_RETURN: offset = dissect_amqp_method_basic_return(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Return"); break; case AMQP_METHOD_BASIC_DELIVER: offset = dissect_amqp_method_basic_deliver(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Deliver"); break; case AMQP_METHOD_BASIC_GET: offset = dissect_amqp_method_basic_get(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Get"); break; case AMQP_METHOD_BASIC_GET_OK: offset = dissect_amqp_method_basic_get_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Get-Ok"); break; case AMQP_METHOD_BASIC_GET_EMPTY: offset = dissect_amqp_method_basic_get_empty(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Get-Empty"); break; case AMQP_METHOD_BASIC_ACK: offset = dissect_amqp_method_basic_ack(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Ack"); break; case AMQP_METHOD_BASIC_REJECT: offset = dissect_amqp_method_basic_reject(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Reject"); break; case AMQP_METHOD_BASIC_RECOVER: offset = dissect_amqp_method_basic_recover(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Basic.Recover"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1430,58 +1580,100 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_FILE_QOS: offset = dissect_amqp_method_file_qos(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Qos"); break; case AMQP_METHOD_FILE_QOS_OK: offset = dissect_amqp_method_file_qos_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Qos-Ok"); break; case AMQP_METHOD_FILE_CONSUME: offset = dissect_amqp_method_file_consume(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Consume"); break; case AMQP_METHOD_FILE_CONSUME_OK: offset = dissect_amqp_method_file_consume_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Consume-Ok"); break; case AMQP_METHOD_FILE_CANCEL: offset = dissect_amqp_method_file_cancel(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Cancel"); break; case AMQP_METHOD_FILE_CANCEL_OK: offset = dissect_amqp_method_file_cancel_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Cancel-Ok"); break; case AMQP_METHOD_FILE_OPEN: offset = dissect_amqp_method_file_open(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Open"); break; case AMQP_METHOD_FILE_OPEN_OK: offset = dissect_amqp_method_file_open_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Open-Ok"); break; case AMQP_METHOD_FILE_STAGE: offset = dissect_amqp_method_file_stage(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Stage"); break; case AMQP_METHOD_FILE_PUBLISH: offset = dissect_amqp_method_file_publish(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Publish"); break; case AMQP_METHOD_FILE_RETURN: offset = dissect_amqp_method_file_return(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Return"); break; case AMQP_METHOD_FILE_DELIVER: offset = dissect_amqp_method_file_deliver(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Deliver"); break; case AMQP_METHOD_FILE_ACK: offset = dissect_amqp_method_file_ack(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Ack"); break; case AMQP_METHOD_FILE_REJECT: offset = dissect_amqp_method_file_reject(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "File.Reject"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1497,38 +1689,65 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_STREAM_QOS: offset = dissect_amqp_method_stream_qos(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Stream.Qos"); break; case AMQP_METHOD_STREAM_QOS_OK: offset = dissect_amqp_method_stream_qos_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Stream.Qos-Ok"); break; case AMQP_METHOD_STREAM_CONSUME: offset = dissect_amqp_method_stream_consume(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Stream.Consume"); break; case AMQP_METHOD_STREAM_CONSUME_OK: offset = dissect_amqp_method_stream_consume_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Stream.Consume-Ok"); break; case AMQP_METHOD_STREAM_CANCEL: offset = dissect_amqp_method_stream_cancel(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Stream.Cancel"); break; case AMQP_METHOD_STREAM_CANCEL_OK: offset = dissect_amqp_method_stream_cancel_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Stream.Cancel-Ok"); break; case AMQP_METHOD_STREAM_PUBLISH: offset = dissect_amqp_method_stream_publish(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Stream.Publish"); break; case AMQP_METHOD_STREAM_RETURN: offset = dissect_amqp_method_stream_return(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Stream.Return"); break; case AMQP_METHOD_STREAM_DELIVER: offset = dissect_amqp_method_stream_deliver(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Stream.Deliver"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1544,26 +1763,44 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_TX_SELECT: offset = dissect_amqp_method_tx_select(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Tx.Select"); break; case AMQP_METHOD_TX_SELECT_OK: offset = dissect_amqp_method_tx_select_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Tx.Select-Ok"); break; case AMQP_METHOD_TX_COMMIT: offset = dissect_amqp_method_tx_commit(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Tx.Commit"); break; case AMQP_METHOD_TX_COMMIT_OK: offset = dissect_amqp_method_tx_commit_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Tx.Commit-Ok"); break; case AMQP_METHOD_TX_ROLLBACK: offset = dissect_amqp_method_tx_rollback(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Tx.Rollback"); break; case AMQP_METHOD_TX_ROLLBACK_OK: offset = dissect_amqp_method_tx_rollback_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Tx.Rollback-Ok"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1579,18 +1816,30 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_DTX_SELECT: offset = dissect_amqp_method_dtx_select(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Dtx.Select"); break; case AMQP_METHOD_DTX_SELECT_OK: offset = dissect_amqp_method_dtx_select_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Dtx.Select-Ok"); break; case AMQP_METHOD_DTX_START: offset = dissect_amqp_method_dtx_start(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Dtx.Start"); break; case AMQP_METHOD_DTX_START_OK: offset = dissect_amqp_method_dtx_start_ok(tvb, 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Dtx.Start-Ok"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1606,49 +1855,9 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) case AMQP_METHOD_TUNNEL_REQUEST: offset = dissect_amqp_method_tunnel_request(tvb, 11, tvb_length (tvb), args_tree); - break; - default: - DISSECTOR_ASSERT(FALSE); - } - break; - case AMQP_CLASS_TEST: - proto_tree_add_item(amqp_tree, hf_amqp_method_test_method_id, - tvb, 9, 2, FALSE); - ti = proto_tree_add_item(amqp_tree, hf_amqp_method_arguments, - tvb, 11, length - 4, FALSE); - args_tree = proto_item_add_subtree(ti, ett_args); - switch (tvb_get_ntohs(tvb, 9)) { - case AMQP_METHOD_TEST_INTEGER: - offset = dissect_amqp_method_test_integer(tvb, - 11, tvb_length (tvb), args_tree); - break; - case AMQP_METHOD_TEST_INTEGER_OK: - offset = dissect_amqp_method_test_integer_ok(tvb, - 11, tvb_length (tvb), args_tree); - break; - case AMQP_METHOD_TEST_STRING: - offset = dissect_amqp_method_test_string(tvb, - 11, tvb_length (tvb), args_tree); - break; - case AMQP_METHOD_TEST_STRING_OK: - offset = dissect_amqp_method_test_string_ok(tvb, - 11, tvb_length (tvb), args_tree); - break; - case AMQP_METHOD_TEST_TABLE: - offset = dissect_amqp_method_test_table(tvb, - 11, tvb_length (tvb), args_tree); - break; - case AMQP_METHOD_TEST_TABLE_OK: - offset = dissect_amqp_method_test_table_ok(tvb, - 11, tvb_length (tvb), args_tree); - break; - case AMQP_METHOD_TEST_CONTENT: - offset = dissect_amqp_method_test_content(tvb, - 11, tvb_length (tvb), args_tree); - break; - case AMQP_METHOD_TEST_CONTENT_OK: - offset = dissect_amqp_method_test_content_ok(tvb, - 11, tvb_length (tvb), args_tree); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, + "Tunnel.Request"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1691,10 +1900,14 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) default: DISSECTOR_ASSERT(FALSE); } + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, "Content header"); break; case AMQP_FRAME_TYPE_CONTENT_BODY: proto_tree_add_item(amqp_tree, hf_amqp_payload, tvb, 7, length, FALSE); + if (check_col(pinfo->cinfo, COL_INFO)) + col_append_fstr(pinfo->cinfo, COL_INFO, "Content body"); break; default: DISSECTOR_ASSERT(FALSE); @@ -1705,21 +1918,21 @@ dissect_amqp_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree) /* Dissection routine for method Connection.Start */ static size_t -dissect_amqp_method_connection_start(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_start(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { proto_item *ti; - /* version major (octet) */ + /* version-major (octet) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_start_version_major, tvb, offset, 1, FALSE); AMQP_INCREMENT(offset, 1, bound); - /* version minor (octet) */ + /* version-minor (octet) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_start_version_minor, tvb, offset, 1, FALSE); AMQP_INCREMENT(offset, 1, bound); - /* server properties (table) */ + /* server-properties (table) */ ti = proto_tree_add_item( args_tree, hf_amqp_method_connection_start_server_properties, tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); @@ -1743,11 +1956,11 @@ dissect_amqp_method_connection_start(tvbuff_t *tvb _U_, /* Dissection routine for method Connection.Start-Ok */ static size_t -dissect_amqp_method_connection_start_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_start_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { proto_item *ti; - /* client properties (table) */ + /* client-properties (table) */ ti = proto_tree_add_item( args_tree, hf_amqp_method_connection_start_ok_client_properties, tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); @@ -1776,8 +1989,8 @@ dissect_amqp_method_connection_start_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Connection.Secure */ static size_t -dissect_amqp_method_connection_secure(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_secure(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* challenge (longstr) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_secure_challenge, @@ -1790,8 +2003,8 @@ dissect_amqp_method_connection_secure(tvbuff_t *tvb _U_, /* Dissection routine for method Connection.Secure-Ok */ static size_t -dissect_amqp_method_connection_secure_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_secure_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* response (longstr) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_secure_ok_response, @@ -1804,15 +2017,15 @@ dissect_amqp_method_connection_secure_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Connection.Tune */ static size_t -dissect_amqp_method_connection_tune(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_tune(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* channel max (short) */ + /* channel-max (short) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_tune_channel_max, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* frame max (long) */ + /* frame-max (long) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_tune_frame_max, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); @@ -1828,15 +2041,15 @@ dissect_amqp_method_connection_tune(tvbuff_t *tvb _U_, /* Dissection routine for method Connection.Tune-Ok */ static size_t -dissect_amqp_method_connection_tune_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_tune_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* channel max (short) */ + /* channel-max (short) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_tune_ok_channel_max, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* frame max (long) */ + /* frame-max (long) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_tune_ok_frame_max, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); @@ -1852,10 +2065,10 @@ dissect_amqp_method_connection_tune_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Connection.Open */ static size_t -dissect_amqp_method_connection_open(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_open(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* virtual host (shortstr) */ + /* virtual-host (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_open_virtual_host, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -1875,10 +2088,10 @@ dissect_amqp_method_connection_open(tvbuff_t *tvb _U_, /* Dissection routine for method Connection.Open-Ok */ static size_t -dissect_amqp_method_connection_open_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_open_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* known hosts (shortstr) */ + /* known-hosts (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_open_ok_known_hosts, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -1889,15 +2102,15 @@ dissect_amqp_method_connection_open_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Connection.Redirect */ static size_t -dissect_amqp_method_connection_redirect(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_redirect(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* host (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_redirect_host, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* known hosts (shortstr) */ + /* known-hosts (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_redirect_known_hosts, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -1908,25 +2121,25 @@ dissect_amqp_method_connection_redirect(tvbuff_t *tvb _U_, /* Dissection routine for method Connection.Close */ static size_t -dissect_amqp_method_connection_close(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_connection_close(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* reply code (short) */ + /* reply-code (short) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_close_reply_code, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* reply text (shortstr) */ + /* reply-text (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_close_reply_text, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* class id (short) */ + /* class-id (short) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_close_class_id, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* method id (short) */ + /* method-id (short) */ proto_tree_add_item(args_tree, hf_amqp_method_connection_close_method_id, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); @@ -1946,10 +2159,10 @@ dissect_amqp_method_connection_close_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Channel.Open */ static size_t -dissect_amqp_method_channel_open(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_channel_open(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* out of band (shortstr) */ + /* out-of-band (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_channel_open_out_of_band, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -1960,17 +2173,22 @@ dissect_amqp_method_channel_open(tvbuff_t *tvb _U_, /* Dissection routine for method Channel.Open-Ok */ static size_t -dissect_amqp_method_channel_open_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_channel_open_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { + /* channel-id (longstr) */ + proto_tree_add_item(args_tree, hf_amqp_method_channel_open_ok_channel_id, + tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); + AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); + return offset; } /* Dissection routine for method Channel.Flow */ static size_t -dissect_amqp_method_channel_flow(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_channel_flow(tvbuff_t *tvb, + int offset, int bound _U_, proto_tree *args_tree) { /* active (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_channel_flow_active, @@ -1982,8 +2200,8 @@ dissect_amqp_method_channel_flow(tvbuff_t *tvb _U_, /* Dissection routine for method Channel.Flow-Ok */ static size_t -dissect_amqp_method_channel_flow_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_channel_flow_ok(tvbuff_t *tvb, + int offset, int bound _U_, proto_tree *args_tree) { /* active (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_channel_flow_ok_active, @@ -1992,56 +2210,28 @@ dissect_amqp_method_channel_flow_ok(tvbuff_t *tvb _U_, return offset; } -/* Dissection routine for method Channel.Alert */ - -static size_t -dissect_amqp_method_channel_alert(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) -{ - proto_item *ti; - /* reply code (short) */ - proto_tree_add_item(args_tree, hf_amqp_method_channel_alert_reply_code, - tvb, offset, 2, FALSE); - AMQP_INCREMENT(offset, 2, bound); - - /* reply text (shortstr) */ - proto_tree_add_item(args_tree, hf_amqp_method_channel_alert_reply_text, - tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); - AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - - /* details (table) */ - ti = proto_tree_add_item( - args_tree, hf_amqp_method_channel_alert_details, - tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); - dissect_amqp_field_table (tvb, offset + 4, - offset + 4 + tvb_get_ntohl(tvb, offset), tvb_get_ntohl(tvb, offset), ti); - AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); - - return offset; -} - /* Dissection routine for method Channel.Close */ static size_t -dissect_amqp_method_channel_close(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_channel_close(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* reply code (short) */ + /* reply-code (short) */ proto_tree_add_item(args_tree, hf_amqp_method_channel_close_reply_code, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* reply text (shortstr) */ + /* reply-text (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_channel_close_reply_text, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* class id (short) */ + /* class-id (short) */ proto_tree_add_item(args_tree, hf_amqp_method_channel_close_class_id, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* method id (short) */ + /* method-id (short) */ proto_tree_add_item(args_tree, hf_amqp_method_channel_close_method_id, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); @@ -2058,12 +2248,53 @@ dissect_amqp_method_channel_close_ok(tvbuff_t *tvb _U_, return offset; } -/* Dissection routine for method Access.Request */ +/* Dissection routine for method Channel.Resume */ static size_t -dissect_amqp_method_access_request(tvbuff_t *tvb _U_, +dissect_amqp_method_channel_resume(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) +{ + /* channel-id (longstr) */ + proto_tree_add_item(args_tree, hf_amqp_method_channel_resume_channel_id, + tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); + AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); + + return offset; +} + +/* Dissection routine for method Channel.Ping */ + +static size_t +dissect_amqp_method_channel_ping(tvbuff_t *tvb _U_, + int offset _U_, int bound _U_, proto_tree *args_tree _U_) +{ + return offset; +} + +/* Dissection routine for method Channel.Pong */ + +static size_t +dissect_amqp_method_channel_pong(tvbuff_t *tvb _U_, + int offset _U_, int bound _U_, proto_tree *args_tree _U_) +{ + return offset; +} + +/* Dissection routine for method Channel.Ok */ + +static size_t +dissect_amqp_method_channel_ok(tvbuff_t *tvb _U_, int offset _U_, int bound _U_, proto_tree *args_tree _U_) { + return offset; +} + +/* Dissection routine for method Access.Request */ + +static size_t +dissect_amqp_method_access_request(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) +{ /* realm (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_access_request_realm, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); @@ -2095,8 +2326,8 @@ dissect_amqp_method_access_request(tvbuff_t *tvb _U_, /* Dissection routine for method Access.Request-Ok */ static size_t -dissect_amqp_method_access_request_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_access_request_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_access_request_ok_ticket, @@ -2109,8 +2340,8 @@ dissect_amqp_method_access_request_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Exchange.Declare */ static size_t -dissect_amqp_method_exchange_declare(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_exchange_declare(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { proto_item *ti; /* ticket (short) */ @@ -2136,7 +2367,7 @@ dissect_amqp_method_exchange_declare(tvbuff_t *tvb _U_, proto_tree_add_item(args_tree, hf_amqp_method_exchange_declare_durable, tvb, offset, 1, FALSE); - /* auto delete (bit) */ + /* auto-delete (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_exchange_declare_auto_delete, tvb, offset, 1, FALSE); @@ -2172,8 +2403,8 @@ dissect_amqp_method_exchange_declare_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Exchange.Delete */ static size_t -dissect_amqp_method_exchange_delete(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_exchange_delete(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_exchange_delete_ticket, @@ -2185,7 +2416,7 @@ dissect_amqp_method_exchange_delete(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* if unused (bit) */ + /* if-unused (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_exchange_delete_if_unused, tvb, offset, 1, FALSE); @@ -2208,8 +2439,8 @@ dissect_amqp_method_exchange_delete_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Queue.Declare */ static size_t -dissect_amqp_method_queue_declare(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_queue_declare(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { proto_item *ti; /* ticket (short) */ @@ -2234,7 +2465,7 @@ dissect_amqp_method_queue_declare(tvbuff_t *tvb _U_, proto_tree_add_item(args_tree, hf_amqp_method_queue_declare_exclusive, tvb, offset, 1, FALSE); - /* auto delete (bit) */ + /* auto-delete (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_declare_auto_delete, tvb, offset, 1, FALSE); @@ -2257,20 +2488,20 @@ dissect_amqp_method_queue_declare(tvbuff_t *tvb _U_, /* Dissection routine for method Queue.Declare-Ok */ static size_t -dissect_amqp_method_queue_declare_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_queue_declare_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* queue (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_declare_ok_queue, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* message count (long) */ + /* message-count (long) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_declare_ok_message_count, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); - /* consumer count (long) */ + /* consumer-count (long) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_declare_ok_consumer_count, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); @@ -2281,8 +2512,8 @@ dissect_amqp_method_queue_declare_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Queue.Bind */ static size_t -dissect_amqp_method_queue_bind(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_queue_bind(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { proto_item *ti; /* ticket (short) */ @@ -2300,7 +2531,7 @@ dissect_amqp_method_queue_bind(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_bind_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2330,12 +2561,59 @@ dissect_amqp_method_queue_bind_ok(tvbuff_t *tvb _U_, return offset; } -/* Dissection routine for method Queue.Purge */ +/* Dissection routine for method Queue.Unbind */ static size_t -dissect_amqp_method_queue_purge(tvbuff_t *tvb _U_, +dissect_amqp_method_queue_unbind(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) +{ + proto_item *ti; + /* ticket (short) */ + proto_tree_add_item(args_tree, hf_amqp_method_queue_unbind_ticket, + tvb, offset, 2, FALSE); + AMQP_INCREMENT(offset, 2, bound); + + /* queue (shortstr) */ + proto_tree_add_item(args_tree, hf_amqp_method_queue_unbind_queue, + tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); + AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); + + /* exchange (shortstr) */ + proto_tree_add_item(args_tree, hf_amqp_method_queue_unbind_exchange, + tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); + AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); + + /* routing-key (shortstr) */ + proto_tree_add_item(args_tree, hf_amqp_method_queue_unbind_routing_key, + tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); + AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); + + /* arguments (table) */ + ti = proto_tree_add_item( + args_tree, hf_amqp_method_queue_unbind_arguments, + tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); + dissect_amqp_field_table (tvb, offset + 4, + offset + 4 + tvb_get_ntohl(tvb, offset), tvb_get_ntohl(tvb, offset), ti); + AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); + + return offset; +} + +/* Dissection routine for method Queue.Unbind-Ok */ + +static size_t +dissect_amqp_method_queue_unbind_ok(tvbuff_t *tvb _U_, int offset _U_, int bound _U_, proto_tree *args_tree _U_) { + return offset; +} + +/* Dissection routine for method Queue.Purge */ + +static size_t +dissect_amqp_method_queue_purge(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) +{ /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_purge_ticket, tvb, offset, 2, FALSE); @@ -2356,10 +2634,10 @@ dissect_amqp_method_queue_purge(tvbuff_t *tvb _U_, /* Dissection routine for method Queue.Purge-Ok */ static size_t -dissect_amqp_method_queue_purge_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_queue_purge_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* message count (long) */ + /* message-count (long) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_purge_ok_message_count, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); @@ -2370,8 +2648,8 @@ dissect_amqp_method_queue_purge_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Queue.Delete */ static size_t -dissect_amqp_method_queue_delete(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_queue_delete(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_delete_ticket, @@ -2383,11 +2661,11 @@ dissect_amqp_method_queue_delete(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* if unused (bit) */ + /* if-unused (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_delete_if_unused, tvb, offset, 1, FALSE); - /* if empty (bit) */ + /* if-empty (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_delete_if_empty, tvb, offset, 1, FALSE); @@ -2401,10 +2679,10 @@ dissect_amqp_method_queue_delete(tvbuff_t *tvb _U_, /* Dissection routine for method Queue.Delete-Ok */ static size_t -dissect_amqp_method_queue_delete_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_queue_delete_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* message count (long) */ + /* message-count (long) */ proto_tree_add_item(args_tree, hf_amqp_method_queue_delete_ok_message_count, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); @@ -2415,15 +2693,15 @@ dissect_amqp_method_queue_delete_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Qos */ static size_t -dissect_amqp_method_basic_qos(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_qos(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* prefetch size (long) */ + /* prefetch-size (long) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_qos_prefetch_size, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); - /* prefetch count (short) */ + /* prefetch-count (short) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_qos_prefetch_count, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); @@ -2447,9 +2725,10 @@ dissect_amqp_method_basic_qos_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Consume */ static size_t -dissect_amqp_method_basic_consume(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_consume(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { + proto_item *ti; /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_consume_ticket, tvb, offset, 2, FALSE); @@ -2460,16 +2739,16 @@ dissect_amqp_method_basic_consume(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_consume_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* no local (bit) */ + /* no-local (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_consume_no_local, tvb, offset, 1, FALSE); - /* no ack (bit) */ + /* no-ack (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_consume_no_ack, tvb, offset, 1, FALSE); @@ -2481,16 +2760,25 @@ dissect_amqp_method_basic_consume(tvbuff_t *tvb _U_, proto_tree_add_item(args_tree, hf_amqp_method_basic_consume_nowait, tvb, offset, 1, FALSE); + AMQP_INCREMENT(offset, 1, bound); + /* filter (table) */ + ti = proto_tree_add_item( + args_tree, hf_amqp_method_basic_consume_filter, + tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); + dissect_amqp_field_table (tvb, offset + 4, + offset + 4 + tvb_get_ntohl(tvb, offset), tvb_get_ntohl(tvb, offset), ti); + AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); + return offset; } /* Dissection routine for method Basic.Consume-Ok */ static size_t -dissect_amqp_method_basic_consume_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_consume_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_consume_ok_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2501,10 +2789,10 @@ dissect_amqp_method_basic_consume_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Cancel */ static size_t -dissect_amqp_method_basic_cancel(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_cancel(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_cancel_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2519,10 +2807,10 @@ dissect_amqp_method_basic_cancel(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Cancel-Ok */ static size_t -dissect_amqp_method_basic_cancel_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_cancel_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_cancel_ok_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2533,8 +2821,8 @@ dissect_amqp_method_basic_cancel_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Publish */ static size_t -dissect_amqp_method_basic_publish(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_publish(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_publish_ticket, @@ -2546,7 +2834,7 @@ dissect_amqp_method_basic_publish(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_publish_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2565,15 +2853,15 @@ dissect_amqp_method_basic_publish(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Return */ static size_t -dissect_amqp_method_basic_return(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_return(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* reply code (short) */ + /* reply-code (short) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_return_reply_code, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* reply text (shortstr) */ + /* reply-text (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_return_reply_text, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2583,7 +2871,7 @@ dissect_amqp_method_basic_return(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_return_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2594,15 +2882,15 @@ dissect_amqp_method_basic_return(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Deliver */ static size_t -dissect_amqp_method_basic_deliver(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_deliver(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_deliver_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* delivery tag (longlong) */ + /* delivery-tag (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_deliver_delivery_tag, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -2617,7 +2905,7 @@ dissect_amqp_method_basic_deliver(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_deliver_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2628,8 +2916,8 @@ dissect_amqp_method_basic_deliver(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Get */ static size_t -dissect_amqp_method_basic_get(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_get(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_get_ticket, @@ -2641,7 +2929,7 @@ dissect_amqp_method_basic_get(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* no ack (bit) */ + /* no-ack (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_get_no_ack, tvb, offset, 1, FALSE); @@ -2651,10 +2939,10 @@ dissect_amqp_method_basic_get(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Get-Ok */ static size_t -dissect_amqp_method_basic_get_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_get_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* delivery tag (longlong) */ + /* delivery-tag (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_get_ok_delivery_tag, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -2669,12 +2957,12 @@ dissect_amqp_method_basic_get_ok(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_get_ok_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* message count (long) */ + /* message-count (long) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_get_ok_message_count, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); @@ -2685,10 +2973,10 @@ dissect_amqp_method_basic_get_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Get-Empty */ static size_t -dissect_amqp_method_basic_get_empty(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_get_empty(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* cluster id (shortstr) */ + /* cluster-id (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_get_empty_cluster_id, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2699,10 +2987,10 @@ dissect_amqp_method_basic_get_empty(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Ack */ static size_t -dissect_amqp_method_basic_ack(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_ack(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* delivery tag (longlong) */ + /* delivery-tag (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_ack_delivery_tag, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -2717,10 +3005,10 @@ dissect_amqp_method_basic_ack(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Reject */ static size_t -dissect_amqp_method_basic_reject(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_reject(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* delivery tag (longlong) */ + /* delivery-tag (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_reject_delivery_tag, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -2735,8 +3023,8 @@ dissect_amqp_method_basic_reject(tvbuff_t *tvb _U_, /* Dissection routine for method Basic.Recover */ static size_t -dissect_amqp_method_basic_recover(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_basic_recover(tvbuff_t *tvb, + int offset, int bound _U_, proto_tree *args_tree) { /* requeue (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_basic_recover_requeue, @@ -2748,15 +3036,15 @@ dissect_amqp_method_basic_recover(tvbuff_t *tvb _U_, /* Dissection routine for method File.Qos */ static size_t -dissect_amqp_method_file_qos(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_qos(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* prefetch size (long) */ + /* prefetch-size (long) */ proto_tree_add_item(args_tree, hf_amqp_method_file_qos_prefetch_size, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); - /* prefetch count (short) */ + /* prefetch-count (short) */ proto_tree_add_item(args_tree, hf_amqp_method_file_qos_prefetch_count, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); @@ -2780,9 +3068,10 @@ dissect_amqp_method_file_qos_ok(tvbuff_t *tvb _U_, /* Dissection routine for method File.Consume */ static size_t -dissect_amqp_method_file_consume(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_consume(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { + proto_item *ti; /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_file_consume_ticket, tvb, offset, 2, FALSE); @@ -2793,16 +3082,16 @@ dissect_amqp_method_file_consume(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_consume_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* no local (bit) */ + /* no-local (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_file_consume_no_local, tvb, offset, 1, FALSE); - /* no ack (bit) */ + /* no-ack (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_file_consume_no_ack, tvb, offset, 1, FALSE); @@ -2814,16 +3103,25 @@ dissect_amqp_method_file_consume(tvbuff_t *tvb _U_, proto_tree_add_item(args_tree, hf_amqp_method_file_consume_nowait, tvb, offset, 1, FALSE); + AMQP_INCREMENT(offset, 1, bound); + /* filter (table) */ + ti = proto_tree_add_item( + args_tree, hf_amqp_method_file_consume_filter, + tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); + dissect_amqp_field_table (tvb, offset + 4, + offset + 4 + tvb_get_ntohl(tvb, offset), tvb_get_ntohl(tvb, offset), ti); + AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); + return offset; } /* Dissection routine for method File.Consume-Ok */ static size_t -dissect_amqp_method_file_consume_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_consume_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_consume_ok_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2834,10 +3132,10 @@ dissect_amqp_method_file_consume_ok(tvbuff_t *tvb _U_, /* Dissection routine for method File.Cancel */ static size_t -dissect_amqp_method_file_cancel(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_cancel(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_cancel_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2852,10 +3150,10 @@ dissect_amqp_method_file_cancel(tvbuff_t *tvb _U_, /* Dissection routine for method File.Cancel-Ok */ static size_t -dissect_amqp_method_file_cancel_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_cancel_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_cancel_ok_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2866,15 +3164,15 @@ dissect_amqp_method_file_cancel_ok(tvbuff_t *tvb _U_, /* Dissection routine for method File.Open */ static size_t -dissect_amqp_method_file_open(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_open(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* identifier (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_open_identifier, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* content size (longlong) */ + /* content-size (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_file_open_content_size, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -2885,10 +3183,10 @@ dissect_amqp_method_file_open(tvbuff_t *tvb _U_, /* Dissection routine for method File.Open-Ok */ static size_t -dissect_amqp_method_file_open_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_open_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* staged size (longlong) */ + /* staged-size (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_file_open_ok_staged_size, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -2908,8 +3206,8 @@ dissect_amqp_method_file_stage(tvbuff_t *tvb _U_, /* Dissection routine for method File.Publish */ static size_t -dissect_amqp_method_file_publish(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_publish(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_file_publish_ticket, @@ -2921,7 +3219,7 @@ dissect_amqp_method_file_publish(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_publish_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2946,15 +3244,15 @@ dissect_amqp_method_file_publish(tvbuff_t *tvb _U_, /* Dissection routine for method File.Return */ static size_t -dissect_amqp_method_file_return(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_return(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* reply code (short) */ + /* reply-code (short) */ proto_tree_add_item(args_tree, hf_amqp_method_file_return_reply_code, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* reply text (shortstr) */ + /* reply-text (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_return_reply_text, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2964,7 +3262,7 @@ dissect_amqp_method_file_return(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_return_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -2975,15 +3273,15 @@ dissect_amqp_method_file_return(tvbuff_t *tvb _U_, /* Dissection routine for method File.Deliver */ static size_t -dissect_amqp_method_file_deliver(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_deliver(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_deliver_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* delivery tag (longlong) */ + /* delivery-tag (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_file_deliver_delivery_tag, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -2998,7 +3296,7 @@ dissect_amqp_method_file_deliver(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_file_deliver_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3014,10 +3312,10 @@ dissect_amqp_method_file_deliver(tvbuff_t *tvb _U_, /* Dissection routine for method File.Ack */ static size_t -dissect_amqp_method_file_ack(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_ack(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* delivery tag (longlong) */ + /* delivery-tag (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_file_ack_delivery_tag, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -3032,10 +3330,10 @@ dissect_amqp_method_file_ack(tvbuff_t *tvb _U_, /* Dissection routine for method File.Reject */ static size_t -dissect_amqp_method_file_reject(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_file_reject(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* delivery tag (longlong) */ + /* delivery-tag (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_file_reject_delivery_tag, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -3050,20 +3348,20 @@ dissect_amqp_method_file_reject(tvbuff_t *tvb _U_, /* Dissection routine for method Stream.Qos */ static size_t -dissect_amqp_method_stream_qos(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_stream_qos(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* prefetch size (long) */ + /* prefetch-size (long) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_qos_prefetch_size, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); - /* prefetch count (short) */ + /* prefetch-count (short) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_qos_prefetch_count, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* consume rate (long) */ + /* consume-rate (long) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_qos_consume_rate, tvb, offset, 4, FALSE); AMQP_INCREMENT(offset, 4, bound); @@ -3087,9 +3385,10 @@ dissect_amqp_method_stream_qos_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Stream.Consume */ static size_t -dissect_amqp_method_stream_consume(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_stream_consume(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { + proto_item *ti; /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_consume_ticket, tvb, offset, 2, FALSE); @@ -3100,12 +3399,12 @@ dissect_amqp_method_stream_consume(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_consume_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* no local (bit) */ + /* no-local (bit) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_consume_no_local, tvb, offset, 1, FALSE); @@ -3117,16 +3416,25 @@ dissect_amqp_method_stream_consume(tvbuff_t *tvb _U_, proto_tree_add_item(args_tree, hf_amqp_method_stream_consume_nowait, tvb, offset, 1, FALSE); + AMQP_INCREMENT(offset, 1, bound); + /* filter (table) */ + ti = proto_tree_add_item( + args_tree, hf_amqp_method_stream_consume_filter, + tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); + dissect_amqp_field_table (tvb, offset + 4, + offset + 4 + tvb_get_ntohl(tvb, offset), tvb_get_ntohl(tvb, offset), ti); + AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); + return offset; } /* Dissection routine for method Stream.Consume-Ok */ static size_t -dissect_amqp_method_stream_consume_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_stream_consume_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_consume_ok_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3137,10 +3445,10 @@ dissect_amqp_method_stream_consume_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Stream.Cancel */ static size_t -dissect_amqp_method_stream_cancel(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_stream_cancel(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_cancel_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3155,10 +3463,10 @@ dissect_amqp_method_stream_cancel(tvbuff_t *tvb _U_, /* Dissection routine for method Stream.Cancel-Ok */ static size_t -dissect_amqp_method_stream_cancel_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_stream_cancel_ok(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_cancel_ok_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3169,8 +3477,8 @@ dissect_amqp_method_stream_cancel_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Stream.Publish */ static size_t -dissect_amqp_method_stream_publish(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_stream_publish(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { /* ticket (short) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_publish_ticket, @@ -3182,7 +3490,7 @@ dissect_amqp_method_stream_publish(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_publish_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3201,15 +3509,15 @@ dissect_amqp_method_stream_publish(tvbuff_t *tvb _U_, /* Dissection routine for method Stream.Return */ static size_t -dissect_amqp_method_stream_return(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_stream_return(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* reply code (short) */ + /* reply-code (short) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_return_reply_code, tvb, offset, 2, FALSE); AMQP_INCREMENT(offset, 2, bound); - /* reply text (shortstr) */ + /* reply-text (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_return_reply_text, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3219,7 +3527,7 @@ dissect_amqp_method_stream_return(tvbuff_t *tvb _U_, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* routing key (shortstr) */ + /* routing-key (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_return_routing_key, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3230,15 +3538,15 @@ dissect_amqp_method_stream_return(tvbuff_t *tvb _U_, /* Dissection routine for method Stream.Deliver */ static size_t -dissect_amqp_method_stream_deliver(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_stream_deliver(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* consumer tag (shortstr) */ + /* consumer-tag (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_deliver_consumer_tag, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - /* delivery tag (longlong) */ + /* delivery-tag (longlong) */ proto_tree_add_item(args_tree, hf_amqp_method_stream_deliver_delivery_tag, tvb, offset, 8, FALSE); AMQP_INCREMENT(offset, 8, bound); @@ -3331,10 +3639,10 @@ dissect_amqp_method_dtx_select_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Dtx.Start */ static size_t -dissect_amqp_method_dtx_start(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_dtx_start(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { - /* dtx identifier (shortstr) */ + /* dtx-identifier (shortstr) */ proto_tree_add_item(args_tree, hf_amqp_method_dtx_start_dtx_identifier, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3354,11 +3662,11 @@ dissect_amqp_method_dtx_start_ok(tvbuff_t *tvb _U_, /* Dissection routine for method Tunnel.Request */ static size_t -dissect_amqp_method_tunnel_request(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) +dissect_amqp_method_tunnel_request(tvbuff_t *tvb, + int offset, int bound, proto_tree *args_tree) { proto_item *ti; - /* meta data (table) */ + /* meta-data (table) */ ti = proto_tree_add_item( args_tree, hf_amqp_method_tunnel_request_meta_data, tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); @@ -3369,162 +3677,6 @@ dissect_amqp_method_tunnel_request(tvbuff_t *tvb _U_, return offset; } -/* Dissection routine for method Test.Integer */ - -static size_t -dissect_amqp_method_test_integer(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) -{ - /* integer 1 (octet) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_integer_integer_1, - tvb, offset, 1, FALSE); - AMQP_INCREMENT(offset, 1, bound); - - /* integer 2 (short) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_integer_integer_2, - tvb, offset, 2, FALSE); - AMQP_INCREMENT(offset, 2, bound); - - /* integer 3 (long) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_integer_integer_3, - tvb, offset, 4, FALSE); - AMQP_INCREMENT(offset, 4, bound); - - /* integer 4 (longlong) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_integer_integer_4, - tvb, offset, 8, FALSE); - AMQP_INCREMENT(offset, 8, bound); - - /* operation (octet) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_integer_operation, - tvb, offset, 1, FALSE); - AMQP_INCREMENT(offset, 1, bound); - - return offset; -} - -/* Dissection routine for method Test.Integer-Ok */ - -static size_t -dissect_amqp_method_test_integer_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) -{ - /* result (longlong) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_integer_ok_result, - tvb, offset, 8, FALSE); - AMQP_INCREMENT(offset, 8, bound); - - return offset; -} - -/* Dissection routine for method Test.String */ - -static size_t -dissect_amqp_method_test_string(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) -{ - /* string 1 (shortstr) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_string_string_1, - tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); - AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); - - /* string 2 (longstr) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_string_string_2, - tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); - AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); - - /* operation (octet) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_string_operation, - tvb, offset, 1, FALSE); - AMQP_INCREMENT(offset, 1, bound); - - return offset; -} - -/* Dissection routine for method Test.String-Ok */ - -static size_t -dissect_amqp_method_test_string_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) -{ - /* result (longstr) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_string_ok_result, - tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); - AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); - - return offset; -} - -/* Dissection routine for method Test.Table */ - -static size_t -dissect_amqp_method_test_table(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) -{ - proto_item *ti; - /* table (table) */ - ti = proto_tree_add_item( - args_tree, hf_amqp_method_test_table_table, - tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); - dissect_amqp_field_table (tvb, offset + 4, - offset + 4 + tvb_get_ntohl(tvb, offset), tvb_get_ntohl(tvb, offset), ti); - AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); - - /* integer op (octet) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_table_integer_op, - tvb, offset, 1, FALSE); - AMQP_INCREMENT(offset, 1, bound); - - /* string op (octet) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_table_string_op, - tvb, offset, 1, FALSE); - AMQP_INCREMENT(offset, 1, bound); - - return offset; -} - -/* Dissection routine for method Test.Table-Ok */ - -static size_t -dissect_amqp_method_test_table_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) -{ - /* integer result (longlong) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_table_ok_integer_result, - tvb, offset, 8, FALSE); - AMQP_INCREMENT(offset, 8, bound); - - /* string result (longstr) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_table_ok_string_result, - tvb, offset + 4, tvb_get_ntohl(tvb, offset), FALSE); - AMQP_INCREMENT(offset, 4 + tvb_get_ntohl(tvb, offset), bound); - - return offset; -} - -/* Dissection routine for method Test.Content */ - -static size_t -dissect_amqp_method_test_content(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) -{ - return offset; -} - -/* Dissection routine for method Test.Content-Ok */ - -static size_t -dissect_amqp_method_test_content_ok(tvbuff_t *tvb _U_, - int offset _U_, int bound _U_, proto_tree *args_tree _U_) -{ - /* content checksum (long) */ - proto_tree_add_item(args_tree, hf_amqp_method_test_content_ok_content_checksum, - tvb, offset, 4, FALSE); - AMQP_INCREMENT(offset, 4, bound); - - return offset; -} - /* Dissection routine for content headers of class basic */ @@ -3537,7 +3689,7 @@ dissect_amqp_content_header_basic(tvbuff_t *tvb, prop_flags = tvb_get_ntohs(tvb, 19); if (prop_flags & 0x8000) { - /* content type (shortstr) */ + /* content-type (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_basic_content_type, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3545,7 +3697,7 @@ dissect_amqp_content_header_basic(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* content encoding (shortstr) */ + /* content-encoding (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_basic_content_encoding, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3564,7 +3716,7 @@ dissect_amqp_content_header_basic(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* delivery mode (octet) */ + /* delivery-mode (octet) */ proto_tree_add_item(prop_tree, hf_amqp_header_basic_delivery_mode, tvb, offset, 1, FALSE); AMQP_INCREMENT(offset, 1, bound); @@ -3580,7 +3732,7 @@ dissect_amqp_content_header_basic(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* correlation id (shortstr) */ + /* correlation-id (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_basic_correlation_id, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3588,7 +3740,7 @@ dissect_amqp_content_header_basic(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* reply to (shortstr) */ + /* reply-to (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_basic_reply_to, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3604,7 +3756,7 @@ dissect_amqp_content_header_basic(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* message id (shortstr) */ + /* message-id (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_basic_message_id, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3628,7 +3780,7 @@ dissect_amqp_content_header_basic(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* user id (shortstr) */ + /* user-id (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_basic_user_id, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3636,7 +3788,7 @@ dissect_amqp_content_header_basic(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* app id (shortstr) */ + /* app-id (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_basic_app_id, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3644,7 +3796,7 @@ dissect_amqp_content_header_basic(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* cluster id (shortstr) */ + /* cluster-id (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_basic_cluster_id, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3665,7 +3817,7 @@ dissect_amqp_content_header_file(tvbuff_t *tvb, prop_flags = tvb_get_ntohs(tvb, 19); if (prop_flags & 0x8000) { - /* content type (shortstr) */ + /* content-type (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_file_content_type, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3673,7 +3825,7 @@ dissect_amqp_content_header_file(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* content encoding (shortstr) */ + /* content-encoding (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_file_content_encoding, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3700,7 +3852,7 @@ dissect_amqp_content_header_file(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* reply to (shortstr) */ + /* reply-to (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_file_reply_to, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3708,7 +3860,7 @@ dissect_amqp_content_header_file(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* message id (shortstr) */ + /* message-id (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_file_message_id, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3732,7 +3884,7 @@ dissect_amqp_content_header_file(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* cluster id (shortstr) */ + /* cluster-id (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_file_cluster_id, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3753,7 +3905,7 @@ dissect_amqp_content_header_stream(tvbuff_t *tvb, prop_flags = tvb_get_ntohs(tvb, 19); if (prop_flags & 0x8000) { - /* content type (shortstr) */ + /* content-type (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_stream_content_type, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3761,7 +3913,7 @@ dissect_amqp_content_header_stream(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* content encoding (shortstr) */ + /* content-encoding (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_stream_content_encoding, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3820,7 +3972,7 @@ dissect_amqp_content_header_tunnel(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* proxy name (shortstr) */ + /* proxy-name (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_tunnel_proxy_name, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3828,7 +3980,7 @@ dissect_amqp_content_header_tunnel(tvbuff_t *tvb, } prop_flags <<= 1; if (prop_flags & 0x8000) { - /* data name (shortstr) */ + /* data-name (shortstr) */ proto_tree_add_item(prop_tree, hf_amqp_header_tunnel_data_name, tvb, offset + 1, tvb_get_guint8(tvb, offset), FALSE); AMQP_INCREMENT(offset, 1 + tvb_get_guint8(tvb, offset), bound); @@ -3918,26 +4070,22 @@ static hf_register_info hf[] = { "Method", "amqp.method.method", FT_UINT16, BASE_DEC, VALS(amqp_method_tunnel_methods), 0x0, "Method ID", HFILL}}, - {&hf_amqp_method_test_method_id, { - "Method", "amqp.method.method", - FT_UINT16, BASE_DEC, VALS(amqp_method_test_methods), 0x0, - "Method ID", HFILL}}, {&hf_amqp_method_arguments, { "Arguments", "amqp.method.arguments", FT_NONE, BASE_NONE, NULL, 0x0, "Method arguments", HFILL}}, {&hf_amqp_method_connection_start_version_major, { - "Version Major", "amqp.method.arguments.version_major", + "Version-Major", "amqp.method.arguments.version_major", FT_UINT8, BASE_DEC, NULL, 0, - "version major", HFILL}}, + "version-major", HFILL}}, {&hf_amqp_method_connection_start_version_minor, { - "Version Minor", "amqp.method.arguments.version_minor", + "Version-Minor", "amqp.method.arguments.version_minor", FT_UINT8, BASE_DEC, NULL, 0, - "version minor", HFILL}}, + "version-minor", HFILL}}, {&hf_amqp_method_connection_start_server_properties, { - "Server Properties", "amqp.method.arguments.server_properties", + "Server-Properties", "amqp.method.arguments.server_properties", FT_NONE, BASE_NONE, NULL, 0, - "server properties", HFILL}}, + "server-properties", HFILL}}, {&hf_amqp_method_connection_start_mechanisms, { "Mechanisms", "amqp.method.arguments.mechanisms", FT_BYTES, BASE_NONE, NULL, 0, @@ -3947,9 +4095,9 @@ static hf_register_info hf[] = { FT_BYTES, BASE_NONE, NULL, 0, "locales", HFILL}}, {&hf_amqp_method_connection_start_ok_client_properties, { - "Client Properties", "amqp.method.arguments.client_properties", + "Client-Properties", "amqp.method.arguments.client_properties", FT_NONE, BASE_NONE, NULL, 0, - "client properties", HFILL}}, + "client-properties", HFILL}}, {&hf_amqp_method_connection_start_ok_mechanism, { "Mechanism", "amqp.method.arguments.mechanism", FT_STRING, BASE_NONE, NULL, 0, @@ -3971,33 +4119,33 @@ static hf_register_info hf[] = { FT_BYTES, BASE_NONE, NULL, 0, "response", HFILL}}, {&hf_amqp_method_connection_tune_channel_max, { - "Channel Max", "amqp.method.arguments.channel_max", + "Channel-Max", "amqp.method.arguments.channel_max", FT_UINT16, BASE_DEC, NULL, 0, - "channel max", HFILL}}, + "channel-max", HFILL}}, {&hf_amqp_method_connection_tune_frame_max, { - "Frame Max", "amqp.method.arguments.frame_max", + "Frame-Max", "amqp.method.arguments.frame_max", FT_UINT32, BASE_DEC, NULL, 0, - "frame max", HFILL}}, + "frame-max", HFILL}}, {&hf_amqp_method_connection_tune_heartbeat, { "Heartbeat", "amqp.method.arguments.heartbeat", FT_UINT16, BASE_DEC, NULL, 0, "heartbeat", HFILL}}, {&hf_amqp_method_connection_tune_ok_channel_max, { - "Channel Max", "amqp.method.arguments.channel_max", + "Channel-Max", "amqp.method.arguments.channel_max", FT_UINT16, BASE_DEC, NULL, 0, - "channel max", HFILL}}, + "channel-max", HFILL}}, {&hf_amqp_method_connection_tune_ok_frame_max, { - "Frame Max", "amqp.method.arguments.frame_max", + "Frame-Max", "amqp.method.arguments.frame_max", FT_UINT32, BASE_DEC, NULL, 0, - "frame max", HFILL}}, + "frame-max", HFILL}}, {&hf_amqp_method_connection_tune_ok_heartbeat, { "Heartbeat", "amqp.method.arguments.heartbeat", FT_UINT16, BASE_DEC, NULL, 0, "heartbeat", HFILL}}, {&hf_amqp_method_connection_open_virtual_host, { - "Virtual Host", "amqp.method.arguments.virtual_host", + "Virtual-Host", "amqp.method.arguments.virtual_host", FT_STRING, BASE_NONE, NULL, 0, - "virtual host", HFILL}}, + "virtual-host", HFILL}}, {&hf_amqp_method_connection_open_capabilities, { "Capabilities", "amqp.method.arguments.capabilities", FT_STRING, BASE_NONE, NULL, 0, @@ -4007,37 +4155,41 @@ static hf_register_info hf[] = { FT_BOOLEAN, 8, NULL, 0x01, "insist", HFILL}}, {&hf_amqp_method_connection_open_ok_known_hosts, { - "Known Hosts", "amqp.method.arguments.known_hosts", + "Known-Hosts", "amqp.method.arguments.known_hosts", FT_STRING, BASE_NONE, NULL, 0, - "known hosts", HFILL}}, + "known-hosts", HFILL}}, {&hf_amqp_method_connection_redirect_host, { "Host", "amqp.method.arguments.host", FT_STRING, BASE_NONE, NULL, 0, "host", HFILL}}, {&hf_amqp_method_connection_redirect_known_hosts, { - "Known Hosts", "amqp.method.arguments.known_hosts", + "Known-Hosts", "amqp.method.arguments.known_hosts", FT_STRING, BASE_NONE, NULL, 0, - "known hosts", HFILL}}, + "known-hosts", HFILL}}, {&hf_amqp_method_connection_close_reply_code, { - "Reply Code", "amqp.method.arguments.reply_code", + "Reply-Code", "amqp.method.arguments.reply_code", FT_UINT16, BASE_DEC, NULL, 0, - "reply code", HFILL}}, + "reply-code", HFILL}}, {&hf_amqp_method_connection_close_reply_text, { - "Reply Text", "amqp.method.arguments.reply_text", + "Reply-Text", "amqp.method.arguments.reply_text", FT_STRING, BASE_NONE, NULL, 0, - "reply text", HFILL}}, + "reply-text", HFILL}}, {&hf_amqp_method_connection_close_class_id, { - "Class Id", "amqp.method.arguments.class_id", + "Class-Id", "amqp.method.arguments.class_id", FT_UINT16, BASE_DEC, NULL, 0, - "class id", HFILL}}, + "class-id", HFILL}}, {&hf_amqp_method_connection_close_method_id, { - "Method Id", "amqp.method.arguments.method_id", + "Method-Id", "amqp.method.arguments.method_id", FT_UINT16, BASE_DEC, NULL, 0, - "method id", HFILL}}, + "method-id", HFILL}}, {&hf_amqp_method_channel_open_out_of_band, { - "Out Of Band", "amqp.method.arguments.out_of_band", + "Out-Of-Band", "amqp.method.arguments.out_of_band", FT_STRING, BASE_NONE, NULL, 0, - "out of band", HFILL}}, + "out-of-band", HFILL}}, + {&hf_amqp_method_channel_open_ok_channel_id, { + "Channel-Id", "amqp.method.arguments.channel_id", + FT_BYTES, BASE_NONE, NULL, 0, + "channel-id", HFILL}}, {&hf_amqp_method_channel_flow_active, { "Active", "amqp.method.arguments.active", FT_BOOLEAN, 8, NULL, 0x01, @@ -4046,34 +4198,26 @@ static hf_register_info hf[] = { "Active", "amqp.method.arguments.active", FT_BOOLEAN, 8, NULL, 0x01, "active", HFILL}}, - {&hf_amqp_method_channel_alert_reply_code, { - "Reply Code", "amqp.method.arguments.reply_code", - FT_UINT16, BASE_DEC, NULL, 0, - "reply code", HFILL}}, - {&hf_amqp_method_channel_alert_reply_text, { - "Reply Text", "amqp.method.arguments.reply_text", - FT_STRING, BASE_NONE, NULL, 0, - "reply text", HFILL}}, - {&hf_amqp_method_channel_alert_details, { - "Details", "amqp.method.arguments.details", - FT_NONE, BASE_NONE, NULL, 0, - "details", HFILL}}, {&hf_amqp_method_channel_close_reply_code, { - "Reply Code", "amqp.method.arguments.reply_code", + "Reply-Code", "amqp.method.arguments.reply_code", FT_UINT16, BASE_DEC, NULL, 0, - "reply code", HFILL}}, + "reply-code", HFILL}}, {&hf_amqp_method_channel_close_reply_text, { - "Reply Text", "amqp.method.arguments.reply_text", + "Reply-Text", "amqp.method.arguments.reply_text", FT_STRING, BASE_NONE, NULL, 0, - "reply text", HFILL}}, + "reply-text", HFILL}}, {&hf_amqp_method_channel_close_class_id, { - "Class Id", "amqp.method.arguments.class_id", + "Class-Id", "amqp.method.arguments.class_id", FT_UINT16, BASE_DEC, NULL, 0, - "class id", HFILL}}, + "class-id", HFILL}}, {&hf_amqp_method_channel_close_method_id, { - "Method Id", "amqp.method.arguments.method_id", + "Method-Id", "amqp.method.arguments.method_id", FT_UINT16, BASE_DEC, NULL, 0, - "method id", HFILL}}, + "method-id", HFILL}}, + {&hf_amqp_method_channel_resume_channel_id, { + "Channel-Id", "amqp.method.arguments.channel_id", + FT_BYTES, BASE_NONE, NULL, 0, + "channel-id", HFILL}}, {&hf_amqp_method_access_request_realm, { "Realm", "amqp.method.arguments.realm", FT_STRING, BASE_NONE, NULL, 0, @@ -4123,9 +4267,9 @@ static hf_register_info hf[] = { FT_BOOLEAN, 8, NULL, 0x02, "durable", HFILL}}, {&hf_amqp_method_exchange_declare_auto_delete, { - "Auto Delete", "amqp.method.arguments.auto_delete", + "Auto-Delete", "amqp.method.arguments.auto_delete", FT_BOOLEAN, 8, NULL, 0x04, - "auto delete", HFILL}}, + "auto-delete", HFILL}}, {&hf_amqp_method_exchange_declare_internal, { "Internal", "amqp.method.arguments.internal", FT_BOOLEAN, 8, NULL, 0x08, @@ -4147,9 +4291,9 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_exchange_delete_if_unused, { - "If Unused", "amqp.method.arguments.if_unused", + "If-Unused", "amqp.method.arguments.if_unused", FT_BOOLEAN, 8, NULL, 0x01, - "if unused", HFILL}}, + "if-unused", HFILL}}, {&hf_amqp_method_exchange_delete_nowait, { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x02, @@ -4175,9 +4319,9 @@ static hf_register_info hf[] = { FT_BOOLEAN, 8, NULL, 0x04, "exclusive", HFILL}}, {&hf_amqp_method_queue_declare_auto_delete, { - "Auto Delete", "amqp.method.arguments.auto_delete", + "Auto-Delete", "amqp.method.arguments.auto_delete", FT_BOOLEAN, 8, NULL, 0x08, - "auto delete", HFILL}}, + "auto-delete", HFILL}}, {&hf_amqp_method_queue_declare_nowait, { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x10, @@ -4191,13 +4335,13 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "queue", HFILL}}, {&hf_amqp_method_queue_declare_ok_message_count, { - "Message Count", "amqp.method.arguments.message_count", + "Message-Count", "amqp.method.arguments.message_count", FT_UINT32, BASE_DEC, NULL, 0, - "message count", HFILL}}, + "message-count", HFILL}}, {&hf_amqp_method_queue_declare_ok_consumer_count, { - "Consumer Count", "amqp.method.arguments.consumer_count", + "Consumer-Count", "amqp.method.arguments.consumer_count", FT_UINT32, BASE_DEC, NULL, 0, - "consumer count", HFILL}}, + "consumer-count", HFILL}}, {&hf_amqp_method_queue_bind_ticket, { "Ticket", "amqp.method.arguments.ticket", FT_UINT16, BASE_DEC, NULL, 0, @@ -4211,9 +4355,9 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_queue_bind_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_queue_bind_nowait, { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x01, @@ -4222,6 +4366,26 @@ static hf_register_info hf[] = { "Arguments", "amqp.method.arguments.arguments", FT_NONE, BASE_NONE, NULL, 0, "arguments", HFILL}}, + {&hf_amqp_method_queue_unbind_ticket, { + "Ticket", "amqp.method.arguments.ticket", + FT_UINT16, BASE_DEC, NULL, 0, + "ticket", HFILL}}, + {&hf_amqp_method_queue_unbind_queue, { + "Queue", "amqp.method.arguments.queue", + FT_STRING, BASE_NONE, NULL, 0, + "queue", HFILL}}, + {&hf_amqp_method_queue_unbind_exchange, { + "Exchange", "amqp.method.arguments.exchange", + FT_STRING, BASE_NONE, NULL, 0, + "exchange", HFILL}}, + {&hf_amqp_method_queue_unbind_routing_key, { + "Routing-Key", "amqp.method.arguments.routing_key", + FT_STRING, BASE_NONE, NULL, 0, + "routing-key", HFILL}}, + {&hf_amqp_method_queue_unbind_arguments, { + "Arguments", "amqp.method.arguments.arguments", + FT_NONE, BASE_NONE, NULL, 0, + "arguments", HFILL}}, {&hf_amqp_method_queue_purge_ticket, { "Ticket", "amqp.method.arguments.ticket", FT_UINT16, BASE_DEC, NULL, 0, @@ -4235,9 +4399,9 @@ static hf_register_info hf[] = { FT_BOOLEAN, 8, NULL, 0x01, "nowait", HFILL}}, {&hf_amqp_method_queue_purge_ok_message_count, { - "Message Count", "amqp.method.arguments.message_count", + "Message-Count", "amqp.method.arguments.message_count", FT_UINT32, BASE_DEC, NULL, 0, - "message count", HFILL}}, + "message-count", HFILL}}, {&hf_amqp_method_queue_delete_ticket, { "Ticket", "amqp.method.arguments.ticket", FT_UINT16, BASE_DEC, NULL, 0, @@ -4247,29 +4411,29 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "queue", HFILL}}, {&hf_amqp_method_queue_delete_if_unused, { - "If Unused", "amqp.method.arguments.if_unused", + "If-Unused", "amqp.method.arguments.if_unused", FT_BOOLEAN, 8, NULL, 0x01, - "if unused", HFILL}}, + "if-unused", HFILL}}, {&hf_amqp_method_queue_delete_if_empty, { - "If Empty", "amqp.method.arguments.if_empty", + "If-Empty", "amqp.method.arguments.if_empty", FT_BOOLEAN, 8, NULL, 0x02, - "if empty", HFILL}}, + "if-empty", HFILL}}, {&hf_amqp_method_queue_delete_nowait, { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x04, "nowait", HFILL}}, {&hf_amqp_method_queue_delete_ok_message_count, { - "Message Count", "amqp.method.arguments.message_count", + "Message-Count", "amqp.method.arguments.message_count", FT_UINT32, BASE_DEC, NULL, 0, - "message count", HFILL}}, + "message-count", HFILL}}, {&hf_amqp_method_basic_qos_prefetch_size, { - "Prefetch Size", "amqp.method.arguments.prefetch_size", + "Prefetch-Size", "amqp.method.arguments.prefetch_size", FT_UINT32, BASE_DEC, NULL, 0, - "prefetch size", HFILL}}, + "prefetch-size", HFILL}}, {&hf_amqp_method_basic_qos_prefetch_count, { - "Prefetch Count", "amqp.method.arguments.prefetch_count", + "Prefetch-Count", "amqp.method.arguments.prefetch_count", FT_UINT16, BASE_DEC, NULL, 0, - "prefetch count", HFILL}}, + "prefetch-count", HFILL}}, {&hf_amqp_method_basic_qos_global, { "Global", "amqp.method.arguments.global", FT_BOOLEAN, 8, NULL, 0x01, @@ -4283,17 +4447,17 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "queue", HFILL}}, {&hf_amqp_method_basic_consume_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_basic_consume_no_local, { - "No Local", "amqp.method.arguments.no_local", + "No-Local", "amqp.method.arguments.no_local", FT_BOOLEAN, 8, NULL, 0x01, - "no local", HFILL}}, + "no-local", HFILL}}, {&hf_amqp_method_basic_consume_no_ack, { - "No Ack", "amqp.method.arguments.no_ack", + "No-Ack", "amqp.method.arguments.no_ack", FT_BOOLEAN, 8, NULL, 0x02, - "no ack", HFILL}}, + "no-ack", HFILL}}, {&hf_amqp_method_basic_consume_exclusive, { "Exclusive", "amqp.method.arguments.exclusive", FT_BOOLEAN, 8, NULL, 0x04, @@ -4302,22 +4466,26 @@ static hf_register_info hf[] = { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x08, "nowait", HFILL}}, + {&hf_amqp_method_basic_consume_filter, { + "Filter", "amqp.method.arguments.filter", + FT_NONE, BASE_NONE, NULL, 0, + "filter", HFILL}}, {&hf_amqp_method_basic_consume_ok_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_basic_cancel_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_basic_cancel_nowait, { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x01, "nowait", HFILL}}, {&hf_amqp_method_basic_cancel_ok_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_basic_publish_ticket, { "Ticket", "amqp.method.arguments.ticket", FT_UINT16, BASE_DEC, NULL, 0, @@ -4327,9 +4495,9 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_basic_publish_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_basic_publish_mandatory, { "Mandatory", "amqp.method.arguments.mandatory", FT_BOOLEAN, 8, NULL, 0x01, @@ -4339,29 +4507,29 @@ static hf_register_info hf[] = { FT_BOOLEAN, 8, NULL, 0x02, "immediate", HFILL}}, {&hf_amqp_method_basic_return_reply_code, { - "Reply Code", "amqp.method.arguments.reply_code", + "Reply-Code", "amqp.method.arguments.reply_code", FT_UINT16, BASE_DEC, NULL, 0, - "reply code", HFILL}}, + "reply-code", HFILL}}, {&hf_amqp_method_basic_return_reply_text, { - "Reply Text", "amqp.method.arguments.reply_text", + "Reply-Text", "amqp.method.arguments.reply_text", FT_STRING, BASE_NONE, NULL, 0, - "reply text", HFILL}}, + "reply-text", HFILL}}, {&hf_amqp_method_basic_return_exchange, { "Exchange", "amqp.method.arguments.exchange", FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_basic_return_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_basic_deliver_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_basic_deliver_delivery_tag, { - "Delivery Tag", "amqp.method.arguments.delivery_tag", + "Delivery-Tag", "amqp.method.arguments.delivery_tag", FT_UINT64, BASE_DEC, NULL, 0, - "delivery tag", HFILL}}, + "delivery-tag", HFILL}}, {&hf_amqp_method_basic_deliver_redelivered, { "Redelivered", "amqp.method.arguments.redelivered", FT_BOOLEAN, 8, NULL, 0x01, @@ -4371,9 +4539,9 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_basic_deliver_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_basic_get_ticket, { "Ticket", "amqp.method.arguments.ticket", FT_UINT16, BASE_DEC, NULL, 0, @@ -4383,13 +4551,13 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "queue", HFILL}}, {&hf_amqp_method_basic_get_no_ack, { - "No Ack", "amqp.method.arguments.no_ack", + "No-Ack", "amqp.method.arguments.no_ack", FT_BOOLEAN, 8, NULL, 0x01, - "no ack", HFILL}}, + "no-ack", HFILL}}, {&hf_amqp_method_basic_get_ok_delivery_tag, { - "Delivery Tag", "amqp.method.arguments.delivery_tag", + "Delivery-Tag", "amqp.method.arguments.delivery_tag", FT_UINT64, BASE_DEC, NULL, 0, - "delivery tag", HFILL}}, + "delivery-tag", HFILL}}, {&hf_amqp_method_basic_get_ok_redelivered, { "Redelivered", "amqp.method.arguments.redelivered", FT_BOOLEAN, 8, NULL, 0x01, @@ -4399,29 +4567,29 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_basic_get_ok_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_basic_get_ok_message_count, { - "Message Count", "amqp.method.arguments.message_count", + "Message-Count", "amqp.method.arguments.message_count", FT_UINT32, BASE_DEC, NULL, 0, - "message count", HFILL}}, + "message-count", HFILL}}, {&hf_amqp_method_basic_get_empty_cluster_id, { - "Cluster Id", "amqp.method.arguments.cluster_id", + "Cluster-Id", "amqp.method.arguments.cluster_id", FT_STRING, BASE_NONE, NULL, 0, - "cluster id", HFILL}}, + "cluster-id", HFILL}}, {&hf_amqp_method_basic_ack_delivery_tag, { - "Delivery Tag", "amqp.method.arguments.delivery_tag", + "Delivery-Tag", "amqp.method.arguments.delivery_tag", FT_UINT64, BASE_DEC, NULL, 0, - "delivery tag", HFILL}}, + "delivery-tag", HFILL}}, {&hf_amqp_method_basic_ack_multiple, { "Multiple", "amqp.method.arguments.multiple", FT_BOOLEAN, 8, NULL, 0x01, "multiple", HFILL}}, {&hf_amqp_method_basic_reject_delivery_tag, { - "Delivery Tag", "amqp.method.arguments.delivery_tag", + "Delivery-Tag", "amqp.method.arguments.delivery_tag", FT_UINT64, BASE_DEC, NULL, 0, - "delivery tag", HFILL}}, + "delivery-tag", HFILL}}, {&hf_amqp_method_basic_reject_requeue, { "Requeue", "amqp.method.arguments.requeue", FT_BOOLEAN, 8, NULL, 0x01, @@ -4431,13 +4599,13 @@ static hf_register_info hf[] = { FT_BOOLEAN, 8, NULL, 0x01, "requeue", HFILL}}, {&hf_amqp_method_file_qos_prefetch_size, { - "Prefetch Size", "amqp.method.arguments.prefetch_size", + "Prefetch-Size", "amqp.method.arguments.prefetch_size", FT_UINT32, BASE_DEC, NULL, 0, - "prefetch size", HFILL}}, + "prefetch-size", HFILL}}, {&hf_amqp_method_file_qos_prefetch_count, { - "Prefetch Count", "amqp.method.arguments.prefetch_count", + "Prefetch-Count", "amqp.method.arguments.prefetch_count", FT_UINT16, BASE_DEC, NULL, 0, - "prefetch count", HFILL}}, + "prefetch-count", HFILL}}, {&hf_amqp_method_file_qos_global, { "Global", "amqp.method.arguments.global", FT_BOOLEAN, 8, NULL, 0x01, @@ -4451,17 +4619,17 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "queue", HFILL}}, {&hf_amqp_method_file_consume_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_file_consume_no_local, { - "No Local", "amqp.method.arguments.no_local", + "No-Local", "amqp.method.arguments.no_local", FT_BOOLEAN, 8, NULL, 0x01, - "no local", HFILL}}, + "no-local", HFILL}}, {&hf_amqp_method_file_consume_no_ack, { - "No Ack", "amqp.method.arguments.no_ack", + "No-Ack", "amqp.method.arguments.no_ack", FT_BOOLEAN, 8, NULL, 0x02, - "no ack", HFILL}}, + "no-ack", HFILL}}, {&hf_amqp_method_file_consume_exclusive, { "Exclusive", "amqp.method.arguments.exclusive", FT_BOOLEAN, 8, NULL, 0x04, @@ -4470,34 +4638,38 @@ static hf_register_info hf[] = { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x08, "nowait", HFILL}}, + {&hf_amqp_method_file_consume_filter, { + "Filter", "amqp.method.arguments.filter", + FT_NONE, BASE_NONE, NULL, 0, + "filter", HFILL}}, {&hf_amqp_method_file_consume_ok_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_file_cancel_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_file_cancel_nowait, { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x01, "nowait", HFILL}}, {&hf_amqp_method_file_cancel_ok_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_file_open_identifier, { "Identifier", "amqp.method.arguments.identifier", FT_STRING, BASE_NONE, NULL, 0, "identifier", HFILL}}, {&hf_amqp_method_file_open_content_size, { - "Content Size", "amqp.method.arguments.content_size", + "Content-Size", "amqp.method.arguments.content_size", FT_UINT64, BASE_DEC, NULL, 0, - "content size", HFILL}}, + "content-size", HFILL}}, {&hf_amqp_method_file_open_ok_staged_size, { - "Staged Size", "amqp.method.arguments.staged_size", + "Staged-Size", "amqp.method.arguments.staged_size", FT_UINT64, BASE_DEC, NULL, 0, - "staged size", HFILL}}, + "staged-size", HFILL}}, {&hf_amqp_method_file_publish_ticket, { "Ticket", "amqp.method.arguments.ticket", FT_UINT16, BASE_DEC, NULL, 0, @@ -4507,9 +4679,9 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_file_publish_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_file_publish_mandatory, { "Mandatory", "amqp.method.arguments.mandatory", FT_BOOLEAN, 8, NULL, 0x01, @@ -4523,29 +4695,29 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "identifier", HFILL}}, {&hf_amqp_method_file_return_reply_code, { - "Reply Code", "amqp.method.arguments.reply_code", + "Reply-Code", "amqp.method.arguments.reply_code", FT_UINT16, BASE_DEC, NULL, 0, - "reply code", HFILL}}, + "reply-code", HFILL}}, {&hf_amqp_method_file_return_reply_text, { - "Reply Text", "amqp.method.arguments.reply_text", + "Reply-Text", "amqp.method.arguments.reply_text", FT_STRING, BASE_NONE, NULL, 0, - "reply text", HFILL}}, + "reply-text", HFILL}}, {&hf_amqp_method_file_return_exchange, { "Exchange", "amqp.method.arguments.exchange", FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_file_return_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_file_deliver_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_file_deliver_delivery_tag, { - "Delivery Tag", "amqp.method.arguments.delivery_tag", + "Delivery-Tag", "amqp.method.arguments.delivery_tag", FT_UINT64, BASE_DEC, NULL, 0, - "delivery tag", HFILL}}, + "delivery-tag", HFILL}}, {&hf_amqp_method_file_deliver_redelivered, { "Redelivered", "amqp.method.arguments.redelivered", FT_BOOLEAN, 8, NULL, 0x01, @@ -4555,41 +4727,41 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_file_deliver_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_file_deliver_identifier, { "Identifier", "amqp.method.arguments.identifier", FT_STRING, BASE_NONE, NULL, 0, "identifier", HFILL}}, {&hf_amqp_method_file_ack_delivery_tag, { - "Delivery Tag", "amqp.method.arguments.delivery_tag", + "Delivery-Tag", "amqp.method.arguments.delivery_tag", FT_UINT64, BASE_DEC, NULL, 0, - "delivery tag", HFILL}}, + "delivery-tag", HFILL}}, {&hf_amqp_method_file_ack_multiple, { "Multiple", "amqp.method.arguments.multiple", FT_BOOLEAN, 8, NULL, 0x01, "multiple", HFILL}}, {&hf_amqp_method_file_reject_delivery_tag, { - "Delivery Tag", "amqp.method.arguments.delivery_tag", + "Delivery-Tag", "amqp.method.arguments.delivery_tag", FT_UINT64, BASE_DEC, NULL, 0, - "delivery tag", HFILL}}, + "delivery-tag", HFILL}}, {&hf_amqp_method_file_reject_requeue, { "Requeue", "amqp.method.arguments.requeue", FT_BOOLEAN, 8, NULL, 0x01, "requeue", HFILL}}, {&hf_amqp_method_stream_qos_prefetch_size, { - "Prefetch Size", "amqp.method.arguments.prefetch_size", + "Prefetch-Size", "amqp.method.arguments.prefetch_size", FT_UINT32, BASE_DEC, NULL, 0, - "prefetch size", HFILL}}, + "prefetch-size", HFILL}}, {&hf_amqp_method_stream_qos_prefetch_count, { - "Prefetch Count", "amqp.method.arguments.prefetch_count", + "Prefetch-Count", "amqp.method.arguments.prefetch_count", FT_UINT16, BASE_DEC, NULL, 0, - "prefetch count", HFILL}}, + "prefetch-count", HFILL}}, {&hf_amqp_method_stream_qos_consume_rate, { - "Consume Rate", "amqp.method.arguments.consume_rate", + "Consume-Rate", "amqp.method.arguments.consume_rate", FT_UINT32, BASE_DEC, NULL, 0, - "consume rate", HFILL}}, + "consume-rate", HFILL}}, {&hf_amqp_method_stream_qos_global, { "Global", "amqp.method.arguments.global", FT_BOOLEAN, 8, NULL, 0x01, @@ -4603,13 +4775,13 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "queue", HFILL}}, {&hf_amqp_method_stream_consume_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_stream_consume_no_local, { - "No Local", "amqp.method.arguments.no_local", + "No-Local", "amqp.method.arguments.no_local", FT_BOOLEAN, 8, NULL, 0x01, - "no local", HFILL}}, + "no-local", HFILL}}, {&hf_amqp_method_stream_consume_exclusive, { "Exclusive", "amqp.method.arguments.exclusive", FT_BOOLEAN, 8, NULL, 0x02, @@ -4618,22 +4790,26 @@ static hf_register_info hf[] = { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x04, "nowait", HFILL}}, + {&hf_amqp_method_stream_consume_filter, { + "Filter", "amqp.method.arguments.filter", + FT_NONE, BASE_NONE, NULL, 0, + "filter", HFILL}}, {&hf_amqp_method_stream_consume_ok_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_stream_cancel_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_stream_cancel_nowait, { "Nowait", "amqp.method.arguments.nowait", FT_BOOLEAN, 8, NULL, 0x01, "nowait", HFILL}}, {&hf_amqp_method_stream_cancel_ok_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_stream_publish_ticket, { "Ticket", "amqp.method.arguments.ticket", FT_UINT16, BASE_DEC, NULL, 0, @@ -4643,9 +4819,9 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_stream_publish_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_stream_publish_mandatory, { "Mandatory", "amqp.method.arguments.mandatory", FT_BOOLEAN, 8, NULL, 0x01, @@ -4655,29 +4831,29 @@ static hf_register_info hf[] = { FT_BOOLEAN, 8, NULL, 0x02, "immediate", HFILL}}, {&hf_amqp_method_stream_return_reply_code, { - "Reply Code", "amqp.method.arguments.reply_code", + "Reply-Code", "amqp.method.arguments.reply_code", FT_UINT16, BASE_DEC, NULL, 0, - "reply code", HFILL}}, + "reply-code", HFILL}}, {&hf_amqp_method_stream_return_reply_text, { - "Reply Text", "amqp.method.arguments.reply_text", + "Reply-Text", "amqp.method.arguments.reply_text", FT_STRING, BASE_NONE, NULL, 0, - "reply text", HFILL}}, + "reply-text", HFILL}}, {&hf_amqp_method_stream_return_exchange, { "Exchange", "amqp.method.arguments.exchange", FT_STRING, BASE_NONE, NULL, 0, "exchange", HFILL}}, {&hf_amqp_method_stream_return_routing_key, { - "Routing Key", "amqp.method.arguments.routing_key", + "Routing-Key", "amqp.method.arguments.routing_key", FT_STRING, BASE_NONE, NULL, 0, - "routing key", HFILL}}, + "routing-key", HFILL}}, {&hf_amqp_method_stream_deliver_consumer_tag, { - "Consumer Tag", "amqp.method.arguments.consumer_tag", + "Consumer-Tag", "amqp.method.arguments.consumer_tag", FT_STRING, BASE_NONE, NULL, 0, - "consumer tag", HFILL}}, + "consumer-tag", HFILL}}, {&hf_amqp_method_stream_deliver_delivery_tag, { - "Delivery Tag", "amqp.method.arguments.delivery_tag", + "Delivery-Tag", "amqp.method.arguments.delivery_tag", FT_UINT64, BASE_DEC, NULL, 0, - "delivery tag", HFILL}}, + "delivery-tag", HFILL}}, {&hf_amqp_method_stream_deliver_exchange, { "Exchange", "amqp.method.arguments.exchange", FT_STRING, BASE_NONE, NULL, 0, @@ -4687,77 +4863,13 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "queue", HFILL}}, {&hf_amqp_method_dtx_start_dtx_identifier, { - "Dtx Identifier", "amqp.method.arguments.dtx_identifier", + "Dtx-Identifier", "amqp.method.arguments.dtx_identifier", FT_STRING, BASE_NONE, NULL, 0, - "dtx identifier", HFILL}}, + "dtx-identifier", HFILL}}, {&hf_amqp_method_tunnel_request_meta_data, { - "Meta Data", "amqp.method.arguments.meta_data", - FT_NONE, BASE_NONE, NULL, 0, - "meta data", HFILL}}, - {&hf_amqp_method_test_integer_integer_1, { - "Integer 1", "amqp.method.arguments.integer_1", - FT_UINT8, BASE_DEC, NULL, 0, - "integer 1", HFILL}}, - {&hf_amqp_method_test_integer_integer_2, { - "Integer 2", "amqp.method.arguments.integer_2", - FT_UINT16, BASE_DEC, NULL, 0, - "integer 2", HFILL}}, - {&hf_amqp_method_test_integer_integer_3, { - "Integer 3", "amqp.method.arguments.integer_3", - FT_UINT32, BASE_DEC, NULL, 0, - "integer 3", HFILL}}, - {&hf_amqp_method_test_integer_integer_4, { - "Integer 4", "amqp.method.arguments.integer_4", - FT_UINT64, BASE_DEC, NULL, 0, - "integer 4", HFILL}}, - {&hf_amqp_method_test_integer_operation, { - "Operation", "amqp.method.arguments.operation", - FT_UINT8, BASE_DEC, NULL, 0, - "operation", HFILL}}, - {&hf_amqp_method_test_integer_ok_result, { - "Result", "amqp.method.arguments.result", - FT_UINT64, BASE_DEC, NULL, 0, - "result", HFILL}}, - {&hf_amqp_method_test_string_string_1, { - "String 1", "amqp.method.arguments.string_1", - FT_STRING, BASE_NONE, NULL, 0, - "string 1", HFILL}}, - {&hf_amqp_method_test_string_string_2, { - "String 2", "amqp.method.arguments.string_2", - FT_BYTES, BASE_NONE, NULL, 0, - "string 2", HFILL}}, - {&hf_amqp_method_test_string_operation, { - "Operation", "amqp.method.arguments.operation", - FT_UINT8, BASE_DEC, NULL, 0, - "operation", HFILL}}, - {&hf_amqp_method_test_string_ok_result, { - "Result", "amqp.method.arguments.result", - FT_BYTES, BASE_NONE, NULL, 0, - "result", HFILL}}, - {&hf_amqp_method_test_table_table, { - "Table", "amqp.method.arguments.table", + "Meta-Data", "amqp.method.arguments.meta_data", FT_NONE, BASE_NONE, NULL, 0, - "table", HFILL}}, - {&hf_amqp_method_test_table_integer_op, { - "Integer Op", "amqp.method.arguments.integer_op", - FT_UINT8, BASE_DEC, NULL, 0, - "integer op", HFILL}}, - {&hf_amqp_method_test_table_string_op, { - "String Op", "amqp.method.arguments.string_op", - FT_UINT8, BASE_DEC, NULL, 0, - "string op", HFILL}}, - {&hf_amqp_method_test_table_ok_integer_result, { - "Integer Result", "amqp.method.arguments.integer_result", - FT_UINT64, BASE_DEC, NULL, 0, - "integer result", HFILL}}, - {&hf_amqp_method_test_table_ok_string_result, { - "String Result", "amqp.method.arguments.string_result", - FT_BYTES, BASE_NONE, NULL, 0, - "string result", HFILL}}, - {&hf_amqp_method_test_content_ok_content_checksum, { - "Content Checksum", "amqp.method.arguments.content_checksum", - FT_UINT32, BASE_DEC, NULL, 0, - "content checksum", HFILL}}, + "meta-data", HFILL}}, {&hf_amqp_field, { "AMQP", "amqp", FT_NONE, BASE_NONE, NULL, 0, @@ -4783,41 +4895,41 @@ static hf_register_info hf[] = { FT_NONE, BASE_NONE, NULL, 0x0, "Message properties", HFILL}}, {&hf_amqp_header_basic_content_type, { - "Content Type", "amqp.method.properties.content_type", + "Content-Type", "amqp.method.properties.content_type", FT_STRING, BASE_NONE, NULL, 0, - "content type", HFILL}}, + "content-type", HFILL}}, {&hf_amqp_header_basic_content_encoding, { - "Content Encoding", "amqp.method.properties.content_encoding", + "Content-Encoding", "amqp.method.properties.content_encoding", FT_STRING, BASE_NONE, NULL, 0, - "content encoding", HFILL}}, + "content-encoding", HFILL}}, {&hf_amqp_header_basic_headers, { "Headers", "amqp.method.properties.headers", FT_NONE, BASE_NONE, NULL, 0, "headers", HFILL}}, {&hf_amqp_header_basic_delivery_mode, { - "Delivery Mode", "amqp.method.properties.delivery_mode", + "Delivery-Mode", "amqp.method.properties.delivery_mode", FT_UINT8, BASE_DEC, NULL, 0, - "delivery mode", HFILL}}, + "delivery-mode", HFILL}}, {&hf_amqp_header_basic_priority, { "Priority", "amqp.method.properties.priority", FT_UINT8, BASE_DEC, NULL, 0, "priority", HFILL}}, {&hf_amqp_header_basic_correlation_id, { - "Correlation Id", "amqp.method.properties.correlation_id", + "Correlation-Id", "amqp.method.properties.correlation_id", FT_STRING, BASE_NONE, NULL, 0, - "correlation id", HFILL}}, + "correlation-id", HFILL}}, {&hf_amqp_header_basic_reply_to, { - "Reply To", "amqp.method.properties.reply_to", + "Reply-To", "amqp.method.properties.reply_to", FT_STRING, BASE_NONE, NULL, 0, - "reply to", HFILL}}, + "reply-to", HFILL}}, {&hf_amqp_header_basic_expiration, { "Expiration", "amqp.method.properties.expiration", FT_STRING, BASE_NONE, NULL, 0, "expiration", HFILL}}, {&hf_amqp_header_basic_message_id, { - "Message Id", "amqp.method.properties.message_id", + "Message-Id", "amqp.method.properties.message_id", FT_STRING, BASE_NONE, NULL, 0, - "message id", HFILL}}, + "message-id", HFILL}}, {&hf_amqp_header_basic_timestamp, { "Timestamp", "amqp.method.properties.timestamp", FT_UINT64, BASE_DEC, NULL, 0, @@ -4827,25 +4939,25 @@ static hf_register_info hf[] = { FT_STRING, BASE_NONE, NULL, 0, "type", HFILL}}, {&hf_amqp_header_basic_user_id, { - "User Id", "amqp.method.properties.user_id", + "User-Id", "amqp.method.properties.user_id", FT_STRING, BASE_NONE, NULL, 0, - "user id", HFILL}}, + "user-id", HFILL}}, {&hf_amqp_header_basic_app_id, { - "App Id", "amqp.method.properties.app_id", + "App-Id", "amqp.method.properties.app_id", FT_STRING, BASE_NONE, NULL, 0, - "app id", HFILL}}, + "app-id", HFILL}}, {&hf_amqp_header_basic_cluster_id, { - "Cluster Id", "amqp.method.properties.cluster_id", + "Cluster-Id", "amqp.method.properties.cluster_id", FT_STRING, BASE_NONE, NULL, 0, - "cluster id", HFILL}}, + "cluster-id", HFILL}}, {&hf_amqp_header_file_content_type, { - "Content Type", "amqp.method.properties.content_type", + "Content-Type", "amqp.method.properties.content_type", FT_STRING, BASE_NONE, NULL, 0, - "content type", HFILL}}, + "content-type", HFILL}}, {&hf_amqp_header_file_content_encoding, { - "Content Encoding", "amqp.method.properties.content_encoding", + "Content-Encoding", "amqp.method.properties.content_encoding", FT_STRING, BASE_NONE, NULL, 0, - "content encoding", HFILL}}, + "content-encoding", HFILL}}, {&hf_amqp_header_file_headers, { "Headers", "amqp.method.properties.headers", FT_NONE, BASE_NONE, NULL, 0, @@ -4855,13 +4967,13 @@ static hf_register_info hf[] = { FT_UINT8, BASE_DEC, NULL, 0, "priority", HFILL}}, {&hf_amqp_header_file_reply_to, { - "Reply To", "amqp.method.properties.reply_to", + "Reply-To", "amqp.method.properties.reply_to", FT_STRING, BASE_NONE, NULL, 0, - "reply to", HFILL}}, + "reply-to", HFILL}}, {&hf_amqp_header_file_message_id, { - "Message Id", "amqp.method.properties.message_id", + "Message-Id", "amqp.method.properties.message_id", FT_STRING, BASE_NONE, NULL, 0, - "message id", HFILL}}, + "message-id", HFILL}}, {&hf_amqp_header_file_filename, { "Filename", "amqp.method.properties.filename", FT_STRING, BASE_NONE, NULL, 0, @@ -4871,17 +4983,17 @@ static hf_register_info hf[] = { FT_UINT64, BASE_DEC, NULL, 0, "timestamp", HFILL}}, {&hf_amqp_header_file_cluster_id, { - "Cluster Id", "amqp.method.properties.cluster_id", + "Cluster-Id", "amqp.method.properties.cluster_id", FT_STRING, BASE_NONE, NULL, 0, - "cluster id", HFILL}}, + "cluster-id", HFILL}}, {&hf_amqp_header_stream_content_type, { - "Content Type", "amqp.method.properties.content_type", + "Content-Type", "amqp.method.properties.content_type", FT_STRING, BASE_NONE, NULL, 0, - "content type", HFILL}}, + "content-type", HFILL}}, {&hf_amqp_header_stream_content_encoding, { - "Content Encoding", "amqp.method.properties.content_encoding", + "Content-Encoding", "amqp.method.properties.content_encoding", FT_STRING, BASE_NONE, NULL, 0, - "content encoding", HFILL}}, + "content-encoding", HFILL}}, {&hf_amqp_header_stream_headers, { "Headers", "amqp.method.properties.headers", FT_NONE, BASE_NONE, NULL, 0, @@ -4899,13 +5011,13 @@ static hf_register_info hf[] = { FT_NONE, BASE_NONE, NULL, 0, "headers", HFILL}}, {&hf_amqp_header_tunnel_proxy_name, { - "Proxy Name", "amqp.method.properties.proxy_name", + "Proxy-Name", "amqp.method.properties.proxy_name", FT_STRING, BASE_NONE, NULL, 0, - "proxy name", HFILL}}, + "proxy-name", HFILL}}, {&hf_amqp_header_tunnel_data_name, { - "Data Name", "amqp.method.properties.data_name", + "Data-Name", "amqp.method.properties.data_name", FT_STRING, BASE_NONE, NULL, 0, - "data name", HFILL}}, + "data-name", HFILL}}, {&hf_amqp_header_tunnel_durable, { "Durable", "amqp.method.properties.durable", FT_UINT8, BASE_DEC, NULL, 0, @@ -4918,6 +5030,26 @@ static hf_register_info hf[] = { "Payload", "amqp.payload", FT_BYTES, BASE_NONE, NULL, 0, "Message payload", HFILL}}, + {&hf_amqp_init_protocol, { + "Protocol", "amqp.init.protocol", + FT_STRING, BASE_NONE, NULL, 0, + "Protocol name", HFILL}}, + {&hf_amqp_init_id_major, { + "Protocol ID Major", "amqp.init.id_major", + FT_UINT8, BASE_DEC, NULL, 0, + "Protocol ID major", HFILL}}, + {&hf_amqp_init_id_minor, { + "Protocol ID Minor", "amqp.init.id_minor", + FT_UINT8, BASE_DEC, NULL, 0, + "Protocol ID minor", HFILL}}, + {&hf_amqp_init_version_major, { + "Version Major", "amqp.init.version_major", + FT_UINT8, BASE_DEC, NULL, 0, + "Protocol version major", HFILL}}, + {&hf_amqp_init_version_minor, { + "Version Minor", "amqp.init.version_minor", + FT_UINT8, BASE_DEC, NULL, 0, + "Protocol version minor", HFILL}} }; /* Setup of protocol subtree array */ @@ -4926,7 +5058,8 @@ static gint *ett [] = { &ett_amqp, &ett_args, &ett_props, - &ett_field_table + &ett_field_table, + &ett_amqp_init }; /* Basic registration functions */ |