/* packet-amqp.c

 *

 * AMQP 0-9, 0-9-1, 0-10 and AMQP 1.0 Wireshark dissector

 *

 * Author: Martin Sustrik <sustrik@imatix.com> (AMQP 0-9)

 * Author: Steve Huston <shuston@riverace.com> (extended for AMQP 0-10)

 * Author: Pavel Moravec <pmoravec@redhat.com> (extended for AMQP 1.0)

 *

 * Copyright (c) 1996-2007 iMatix Corporation

 *

 * Wireshark - Network traffic analyzer

 * By Gerald Combs <gerald@wireshark.org>

 * Copyright 1998 Gerald Combs

 *

 * SPDX-License-Identifier: GPL-2.0-or-later

 */

/*

 * See

 *     http://www.amqp.org/resources/download

 *     http://www.rabbitmq.com/protocol.html

 *

 * for specifications for various versions of the AMQP protocol.

 */

#include "config.h"

#include <math.h>

#include <epan/packet.h>

#include <epan/expert.h>

#include <epan/prefs.h>

#include <epan/decode_as.h>

#include <epan/to_str.h>

#include <epan/proto_data.h>

#include <epan/tfs.h>

#include <wsutil/str_util.h>

#include <epan/uat.h>

#include "packet-tcp.h"

#include "packet-tls.h"

void proto_register_amqp(void);

void proto_reg_handoff_amqp(void);

/*  Generic data  */

#define AMQP_PORT   5672

static unsigned amqps_port = 5671; /* AMQP over SSL/TLS */

/*

 * This dissector handles AMQP 0-9, 0-10 and 1.0. The conversation structure

 * contains the version being run - it's only really reliably detected at

 * protocol init. If this dissector starts in the middle of a conversation

 * it will try to figure it out, but conversation start is the best.

 */

/* #define AMQP_V0_8           1 */

#define AMQP_V0_9           2

/* #define AMQP_V0_91          3 */

#define AMQP_V0_10          4

#define AMQP_V1_0           5

typedef struct {

    uint8_t version;

    wmem_map_t *channels; /* maps channel_num to amqp_channel_t */

} amqp_conv;

static dissector_table_t version_table;

static dissector_table_t media_type_subdissector_table;

struct amqp_delivery;

typedef struct amqp_delivery amqp_delivery;

struct amqp_delivery {

    uint64_t delivery_tag;          /* message number or delivery tag */

    uint32_t msg_framenum;          /* basic.publish or basic.deliver frame */

    uint32_t ack_framenum;          /* basic.ack or basic.nack frame */

    amqp_delivery *prev;

};

typedef struct {

    char *type;        /* content type */

    char *encoding;    /* content encoding. Not used in subdissector now */

} amqp_content_params;

typedef struct _amqp_channel_t {

    amqp_conv *conn;

    bool confirms;                   /* true if publisher confirms are enabled */

    uint16_t channel_num;                 /* channel number */

    uint64_t publish_count;               /* number of messages published so far */

    amqp_delivery *last_delivery1;       /* list of unacked messages on tcp flow1 */

    amqp_delivery *last_delivery2;       /* list of unacked messages on tcp flow2 */

    amqp_content_params *content_params; /* parameters of content */

} amqp_channel_t;

typedef struct _amqp_message_decode_t {

    uint32_t match_criteria;

    char *topic_pattern;

    GRegex *topic_regex;

    char *payload_proto_name;

    dissector_handle_t payload_proto;

    char *topic_more_info;

} amqp_message_decode_t;

#define MATCH_CRITERIA_EQUAL        0

#define MATCH_CRITERIA_CONTAINS     1

#define MATCH_CRITERIA_STARTS_WITH  2

#define MATCH_CRITERIA_ENDS_WITH    3

#define MATCH_CRITERIA_REGEX        4

static const value_string match_criteria[] = {

    { MATCH_CRITERIA_EQUAL,       "Equal to" },

    { MATCH_CRITERIA_CONTAINS,    "Contains" },

    { MATCH_CRITERIA_STARTS_WITH, "Starts with" },

    { MATCH_CRITERIA_ENDS_WITH,   "Ends with" },

    { MATCH_CRITERIA_REGEX,       "Regular Expression" },

    { 0, NULL }

};

#define MAX_BUFFER 256

/* 0-9 and 0-9-1 defines */

#define AMQP_0_9_FRAME_TYPE_METHOD                                      1

#define AMQP_0_9_FRAME_TYPE_CONTENT_HEADER                              2

#define AMQP_0_9_FRAME_TYPE_CONTENT_BODY                                3

#define AMQP_0_9_FRAME_TYPE_OOB_METHOD                                  4

#define AMQP_0_9_FRAME_TYPE_OOB_CONTENT_HEADER                          5

#define AMQP_0_9_FRAME_TYPE_OOB_CONTENT_BODY                            6

#define AMQP_0_9_FRAME_TYPE_TRACE                                       7

#define AMQP_0_9_FRAME_TYPE_HEARTBEAT                                   8

#define AMQP_0_9_CLASS_CONNECTION                                      10

#define AMQP_0_9_CLASS_CHANNEL                                         20

#define AMQP_0_9_CLASS_ACCESS                                          30

#define AMQP_0_9_CLASS_EXCHANGE                                        40

#define AMQP_0_9_CLASS_QUEUE                                           50

#define AMQP_0_9_CLASS_BASIC                                           60

#define AMQP_0_9_CLASS_FILE                                            70

#define AMQP_0_9_CLASS_STREAM                                          80

#define AMQP_0_9_CLASS_TX                                              90

#define AMQP_0_9_CLASS_DTX                                            100

#define AMQP_0_9_CLASS_TUNNEL                                         110

#define AMQP_0_9_CLASS_CONFIRM                                         85

#define AMQP_0_9_METHOD_CONNECTION_START                               10

#define AMQP_0_9_METHOD_CONNECTION_START_OK                            11

#define AMQP_0_9_METHOD_CONNECTION_SECURE                              20

#define AMQP_0_9_METHOD_CONNECTION_SECURE_OK                           21

#define AMQP_0_9_METHOD_CONNECTION_TUNE                                30

#define AMQP_0_9_METHOD_CONNECTION_TUNE_OK                             31

#define AMQP_0_9_METHOD_CONNECTION_OPEN                                40

#define AMQP_0_9_METHOD_CONNECTION_OPEN_OK                             41

#define AMQP_0_9_METHOD_CONNECTION_REDIRECT                            42

#define AMQP_0_9_METHOD_CONNECTION_CLOSE                               50

#define AMQP_0_9_METHOD_CONNECTION_CLOSE_OK                            51

#define AMQP_0_9_METHOD_CONNECTION_BLOCKED                             60

#define AMQP_0_9_METHOD_CONNECTION_UNBLOCKED                           61

#define AMQP_0_9_METHOD_CHANNEL_OPEN                                   10

#define AMQP_0_9_METHOD_CHANNEL_OPEN_OK                                11

#define AMQP_0_9_METHOD_CHANNEL_FLOW                                   20

#define AMQP_0_9_METHOD_CHANNEL_FLOW_OK                                21

#define AMQP_0_9_METHOD_CHANNEL_CLOSE                                  40

#define AMQP_0_9_METHOD_CHANNEL_CLOSE_OK                               41

#define AMQP_0_9_METHOD_CHANNEL_RESUME                                 50

#define AMQP_0_9_METHOD_CHANNEL_PING                                   60

#define AMQP_0_9_METHOD_CHANNEL_PONG                                   70

#define AMQP_0_9_METHOD_CHANNEL_OK                                     80

#define AMQP_0_9_METHOD_ACCESS_REQUEST                                 10

#define AMQP_0_9_METHOD_ACCESS_REQUEST_OK                              11

#define AMQP_0_9_METHOD_EXCHANGE_DECLARE                               10

#define AMQP_0_9_METHOD_EXCHANGE_DECLARE_OK                            11

#define AMQP_0_9_METHOD_EXCHANGE_DELETE                                20

#define AMQP_0_9_METHOD_EXCHANGE_DELETE_OK                             21

#define AMQP_0_9_METHOD_EXCHANGE_BIND                                  30

#define AMQP_0_9_METHOD_EXCHANGE_BIND_OK                               31

#define AMQP_0_9_METHOD_EXCHANGE_UNBIND                                40

#define AMQP_0_9_METHOD_EXCHANGE_UNBIND_OK                             51

#define AMQP_0_9_METHOD_QUEUE_DECLARE                                  10

#define AMQP_0_9_METHOD_QUEUE_DECLARE_OK                               11

#define AMQP_0_9_METHOD_QUEUE_BIND                                     20

#define AMQP_0_9_METHOD_QUEUE_BIND_OK                                  21

#define AMQP_0_9_METHOD_QUEUE_UNBIND                                   50

#define AMQP_0_9_METHOD_QUEUE_UNBIND_OK                                51

#define AMQP_0_9_METHOD_QUEUE_PURGE                                    30

#define AMQP_0_9_METHOD_QUEUE_PURGE_OK                                 31

#define AMQP_0_9_METHOD_QUEUE_DELETE                                   40

#define AMQP_0_9_METHOD_QUEUE_DELETE_OK                                41

#define AMQP_0_9_METHOD_BASIC_QOS                                      10

#define AMQP_0_9_METHOD_BASIC_QOS_OK                                   11

#define AMQP_0_9_METHOD_BASIC_CONSUME                                  20

#define AMQP_0_9_METHOD_BASIC_CONSUME_OK                               21

#define AMQP_0_9_METHOD_BASIC_CANCEL                                   30

#define AMQP_0_9_METHOD_BASIC_CANCEL_OK                                31

#define AMQP_0_9_METHOD_BASIC_PUBLISH                                  40

#define AMQP_0_9_METHOD_BASIC_RETURN                                   50

#define AMQP_0_9_METHOD_BASIC_DELIVER                                  60

#define AMQP_0_9_METHOD_BASIC_GET                                      70

#define AMQP_0_9_METHOD_BASIC_GET_OK                                   71

#define AMQP_0_9_METHOD_BASIC_GET_EMPTY                                72

#define AMQP_0_9_METHOD_BASIC_ACK                                      80

#define AMQP_0_9_METHOD_BASIC_REJECT                                   90

/* basic(100) is in 0-9 called Recover and in 0-9-1 Recover.Async,

 * we will use the more recent 0-9-1 terminology */

#define AMQP_0_9_METHOD_BASIC_RECOVER_ASYNC                           100

#define AMQP_0_9_METHOD_BASIC_RECOVER                                 110

#define AMQP_0_9_METHOD_BASIC_RECOVER_OK                              111

#define AMQP_0_9_METHOD_BASIC_NACK                                    120

#define AMQP_0_9_METHOD_FILE_QOS                                       10

#define AMQP_0_9_METHOD_FILE_QOS_OK                                    11

#define AMQP_0_9_METHOD_FILE_CONSUME                                   20

#define AMQP_0_9_METHOD_FILE_CONSUME_OK                                21

#define AMQP_0_9_METHOD_FILE_CANCEL                                    30

#define AMQP_0_9_METHOD_FILE_CANCEL_OK                                 31

#define AMQP_0_9_METHOD_FILE_OPEN                                      40

#define AMQP_0_9_METHOD_FILE_OPEN_OK                                   41

#define AMQP_0_9_METHOD_FILE_STAGE                                     50

#define AMQP_0_9_METHOD_FILE_PUBLISH                                   60

#define AMQP_0_9_METHOD_FILE_RETURN                                    70

#define AMQP_0_9_METHOD_FILE_DELIVER                                   80

#define AMQP_0_9_METHOD_FILE_ACK                                       90

#define AMQP_0_9_METHOD_FILE_REJECT                                   100

#define AMQP_0_9_METHOD_STREAM_QOS                                     10

#define AMQP_0_9_METHOD_STREAM_QOS_OK                                  11

#define AMQP_0_9_METHOD_STREAM_CONSUME                                 20

#define AMQP_0_9_METHOD_STREAM_CONSUME_OK                              21

#define AMQP_0_9_METHOD_STREAM_CANCEL                                  30

#define AMQP_0_9_METHOD_STREAM_CANCEL_OK                               31

#define AMQP_0_9_METHOD_STREAM_PUBLISH                                 40

#define AMQP_0_9_METHOD_STREAM_RETURN                                  50

#define AMQP_0_9_METHOD_STREAM_DELIVER                                 60

#define AMQP_0_9_METHOD_TX_SELECT                                      10

#define AMQP_0_9_METHOD_TX_SELECT_OK                                   11

#define AMQP_0_9_METHOD_TX_COMMIT                                      20

#define AMQP_0_9_METHOD_TX_COMMIT_OK                                   21

#define AMQP_0_9_METHOD_TX_ROLLBACK                                    30

#define AMQP_0_9_METHOD_TX_ROLLBACK_OK                                 31

#define AMQP_0_9_METHOD_DTX_SELECT                                     10

#define AMQP_0_9_METHOD_DTX_SELECT_OK                                  11

#define AMQP_0_9_METHOD_DTX_START                                      20

#define AMQP_0_9_METHOD_DTX_START_OK                                   21

#define AMQP_0_9_METHOD_TUNNEL_REQUEST                                 10

#define AMQP_0_9_METHOD_CONFIRM_SELECT                                 10

#define AMQP_0_9_METHOD_CONFIRM_SELECT_OK                              11

/* AMQP 1.0 values */

#define AMQP_1_0_AMQP_FRAME 0

#define AMQP_1_0_SASL_FRAME 1

#define AMQP_1_0_TLS_FRAME  2

#define AMQP_1_0_AMQP_OPEN        0x10

#define AMQP_1_0_AMQP_BEGIN       0x11

#define AMQP_1_0_AMQP_ATTACH      0x12

#define AMQP_1_0_AMQP_FLOW        0x13

#define AMQP_1_0_AMQP_TRANSFER    0x14

#define AMQP_1_0_AMQP_DISPOSITION 0x15

#define AMQP_1_0_AMQP_DETACH      0x16

#define AMQP_1_0_AMQP_END         0x17

#define AMQP_1_0_AMQP_CLOSE       0x18

#define AMQP_1_0_SASL_MECHANISMS 0x40

#define AMQP_1_0_SASL_INIT       0x41

#define AMQP_1_0_SASL_CHALLENGE  0x42

#define AMQP_1_0_SASL_RESPONSE   0x43

#define AMQP_1_0_SASL_OUTCOME    0x44

#define AMQP_1_0_AMQP_TYPE_ERROR 0x1d

#define AMQP_1_0_AMQP_TYPE_HEADER 0x70

#define AMQP_1_0_AMQP_TYPE_DELIVERY_ANNOTATIONS 0x71

#define AMQP_1_0_AMQP_TYPE_MESSAGE_ANNOTATIONS 0x72

#define AMQP_1_0_AMQP_TYPE_PROPERTIES 0x73

#define AMQP_1_0_AMQP_TYPE_APPLICATION_PROPERTIES 0x74

#define AMQP_1_0_AMQP_TYPE_DATA 0x75

#define AMQP_1_0_AMQP_TYPE_AMQP_SEQUENCE 0x76

#define AMQP_1_0_AMQP_TYPE_AMQP_VALUE 0x77

#define AMQP_1_0_AMQP_TYPE_FOOTER 0x78

#define AMQP_1_0_AMQP_TYPE_RECEIVED 0x23

#define AMQP_1_0_AMQP_TYPE_ACCEPTED 0x24

#define AMQP_1_0_AMQP_TYPE_REJECTED 0x25

#define AMQP_1_0_AMQP_TYPE_RELEASED 0x26

#define AMQP_1_0_AMQP_TYPE_MODIFIED 0x27

#define AMQP_1_0_AMQP_TYPE_SOURCE 0x28

#define AMQP_1_0_AMQP_TYPE_TARGET 0x29

#define AMQP_1_0_AMQP_TYPE_DELETE_ON_CLOSE 0x2b

#define AMQP_1_0_AMQP_TYPE_DELETE_ON_NO_LINKS 0x2c

#define AMQP_1_0_AMQP_TYPE_DELETE_ON_NO_MESSAGE 0x2d

#define AMQP_1_0_AMQP_TYPE_DELETE_ON_NO_LINKS_OR_MESSAGE 0x2e

#define AMQP_1_0_AMQP_TYPE_COORDINATOR 0x30

#define AMQP_1_0_AMQP_TYPE_DECLARE 0x31

#define AMQP_1_0_AMQP_TYPE_DISCHARGE 0x32

#define AMQP_1_0_AMQP_TYPE_DECLARED 0x33

#define AMQP_1_0_AMQP_TYPE_TRANSACTIONAL_STATE 0x34

#define AMQP_1_0_TYPE_DESCRIPTOR_CONSTRUCTOR 0x00

#define AMQP_1_0_TYPE_NULL   0x40

#define AMQP_1_0_TYPE_LIST0   0x45

#define AMQP_1_0_TYPE_LIST8   0xc0

#define AMQP_1_0_TYPE_LIST32   0xd0

#define AMQP_1_0_TYPE_MAP8   0xc1

#define AMQP_1_0_TYPE_MAP32   0xd1

#define AMQP_1_0_TYPE_ARRAY8   0xe0

#define AMQP_1_0_TYPE_ARRAY32   0xf0

/* AMQP 0-10 values */

#define AMQP_0_10_FRAME_CONTROL  0

#define AMQP_0_10_FRAME_COMMAND  1

#define AMQP_0_10_FRAME_HEADER   2

#define AMQP_0_10_FRAME_BODY     3

#define AMQP_0_10_TYPE_STR16     0x95

#define AMQP_0_10_TYPE_MAP       0xa8

#define AMQP_0_10_TYPE_LIST      0xa9

#define AMQP_0_10_TYPE_ARRAY     0xaa

#define AMQP_0_10_TYPE_STRUCT32  0xab

#define AMQP_0_10_CLASS_CONNECTION           0x01

#define AMQP_0_10_METHOD_CONNECTION_START          0x01

#define AMQP_0_10_METHOD_CONNECTION_START_OK       0x02

#define AMQP_0_10_METHOD_CONNECTION_SECURE         0x03

#define AMQP_0_10_METHOD_CONNECTION_SECURE_OK      0x04

#define AMQP_0_10_METHOD_CONNECTION_TUNE           0x05

#define AMQP_0_10_METHOD_CONNECTION_TUNE_OK        0x06

#define AMQP_0_10_METHOD_CONNECTION_OPEN           0x07

#define AMQP_0_10_METHOD_CONNECTION_OPEN_OK        0x08

#define AMQP_0_10_METHOD_CONNECTION_REDIRECT       0x09

#define AMQP_0_10_METHOD_CONNECTION_HEARTBEAT      0x0a

#define AMQP_0_10_METHOD_CONNECTION_CLOSE          0x0b

#define AMQP_0_10_METHOD_CONNECTION_CLOSE_OK       0x0c

#define AMQP_0_10_CLASS_SESSION              0x02

#define AMQP_0_10_METHOD_SESSION_ATTACH            0x01

#define AMQP_0_10_METHOD_SESSION_ATTACHED          0x02

#define AMQP_0_10_METHOD_SESSION_DETACH            0x03

#define AMQP_0_10_METHOD_SESSION_DETACHED          0x04

#define AMQP_0_10_METHOD_SESSION_REQUEST_TIMEOUT   0x05

#define AMQP_0_10_METHOD_SESSION_TIMEOUT           0x06

#define AMQP_0_10_METHOD_SESSION_COMMAND_POINT     0x07

#define AMQP_0_10_METHOD_SESSION_EXPECTED          0x08

#define AMQP_0_10_METHOD_SESSION_CONFIRMED         0x09

#define AMQP_0_10_METHOD_SESSION_COMPLETED         0x0a

#define AMQP_0_10_METHOD_SESSION_KNOWN_COMPLETED   0x0b

#define AMQP_0_10_METHOD_SESSION_FLUSH             0x0c

#define AMQP_0_10_METHOD_SESSION_GAP               0x0d

#define AMQP_0_10_CLASS_EXECUTION            0x03

#define AMQP_0_10_METHOD_EXECUTION_SYNC            0x01

#define AMQP_0_10_METHOD_EXECUTION_RESULT          0x02

#define AMQP_0_10_METHOD_EXECUTION_EXCEPTION       0x03

#define AMQP_0_10_CLASS_MESSAGE              0x04

#define AMQP_0_10_STRUCT_MESSAGE_DELIVERY_PROPERTIES   0x01

#define AMQP_0_10_STRUCT_MESSAGE_FRAGMENT_PROPERTIES   0x02

#define AMQP_0_10_STRUCT_MESSAGE_MESSAGE_PROPERTIES    0x03

#define AMQP_0_10_STRUCT_MESSAGE_ACQUIRED              0x04

#define AMQP_0_10_STRUCT_MESSAGE_RESUME_RESULT         0x05

#define AMQP_0_10_METHOD_MESSAGE_TRANSFER          0x01

#define AMQP_0_10_METHOD_MESSAGE_ACCEPT            0x02

#define AMQP_0_10_METHOD_MESSAGE_REJECT            0x03

#define AMQP_0_10_METHOD_MESSAGE_RELEASE           0x04

#define AMQP_0_10_METHOD_MESSAGE_ACQUIRE           0x05

#define AMQP_0_10_METHOD_MESSAGE_RESUME            0x06

#define AMQP_0_10_METHOD_MESSAGE_SUBSCRIBE         0x07

#define AMQP_0_10_METHOD_MESSAGE_CANCEL            0x08

#define AMQP_0_10_METHOD_MESSAGE_SET_FLOW_MODE     0x09

#define AMQP_0_10_METHOD_MESSAGE_FLOW              0x0a

#define AMQP_0_10_METHOD_MESSAGE_FLUSH             0x0b

#define AMQP_0_10_METHOD_MESSAGE_STOP              0x0c

#define AMQP_0_10_CLASS_TX                   0x05

#define AMQP_0_10_METHOD_TX_SELECT                 0x01

#define AMQP_0_10_METHOD_TX_COMMIT                 0x02

#define AMQP_0_10_METHOD_TX_ROLLBACK               0x03

#define AMQP_0_10_CLASS_DTX                  0x06

#define AMQP_0_10_STRUCT_DTX_XA_RESULT          0x01

#define AMQP_0_10_STRUCT_DTX_RECOVER_RESULT     0x03

#define AMQP_0_10_METHOD_DTX_SELECT                0x01

#define AMQP_0_10_METHOD_DTX_START                 0x02

#define AMQP_0_10_METHOD_DTX_END                   0x03

#define AMQP_0_10_METHOD_DTX_COMMIT                0x04

#define AMQP_0_10_METHOD_DTX_FORGET                0x05

#define AMQP_0_10_METHOD_DTX_GET_TIMEOUT           0x06

#define AMQP_0_10_METHOD_DTX_PREPARE               0x07

#define AMQP_0_10_METHOD_DTX_RECOVER               0x08

#define AMQP_0_10_METHOD_DTX_ROLLBACK              0x09

#define AMQP_0_10_METHOD_DTX_SET_TIMEOUT           0x0a

#define AMQP_0_10_CLASS_EXCHANGE             0x07

#define AMQP_0_10_STRUCT_EXCHANGE_QUERY_RESULT  0x01

#define AMQP_0_10_STRUCT_EXCHANGE_BOUND_RESULT  0x02

#define AMQP_0_10_METHOD_EXCHANGE_DECLARE          0x01

#define AMQP_0_10_METHOD_EXCHANGE_DELETE           0x02

#define AMQP_0_10_METHOD_EXCHANGE_QUERY            0x03

#define AMQP_0_10_METHOD_EXCHANGE_BIND             0x04

#define AMQP_0_10_METHOD_EXCHANGE_UNBIND           0x05

#define AMQP_0_10_METHOD_EXCHANGE_BOUND            0x06

#define AMQP_0_10_CLASS_QUEUE                0x08

#define AMQP_0_10_STRUCT_QUEUE_QUERY_RESULT     0x01

#define AMQP_0_10_METHOD_QUEUE_DECLARE             0x01

#define AMQP_0_10_METHOD_QUEUE_DELETE              0x02

#define AMQP_0_10_METHOD_QUEUE_PURGE               0x03

#define AMQP_0_10_METHOD_QUEUE_QUERY               0x04

#define AMQP_0_10_CLASS_FILE                 0x09

#define AMQP_0_10_STRUCT_FILE_PROPERTIES        0x01

#define AMQP_0_10_METHOD_FILE_QOS                  0x01

#define AMQP_0_10_METHOD_FILE_QOS_OK               0x02

#define AMQP_0_10_METHOD_FILE_CONSUME              0x03

#define AMQP_0_10_METHOD_FILE_CONSUME_OK           0x04

#define AMQP_0_10_METHOD_FILE_CANCEL               0x05

#define AMQP_0_10_METHOD_FILE_OPEN                 0x06

#define AMQP_0_10_METHOD_FILE_OPEN_OK              0x07

#define AMQP_0_10_METHOD_FILE_STAGE                0x08

#define AMQP_0_10_METHOD_FILE_PUBLISH              0x09

#define AMQP_0_10_METHOD_FILE_RETURN               0x0a

#define AMQP_0_10_METHOD_FILE_DELIVER              0x0b

#define AMQP_0_10_METHOD_FILE_ACK                  0x0c

#define AMQP_0_10_METHOD_FILE_REJECT               0x0d

#define AMQP_0_10_CLASS_STREAM               0x0a

#define AMQP_0_10_STRUCT_STREAM_PROPERTIES      0x01

#define AMQP_0_10_METHOD_STREAM_QOS                0x01

#define AMQP_0_10_METHOD_STREAM_QOS_OK             0x02

#define AMQP_0_10_METHOD_STREAM_CONSUME            0x03

#define AMQP_0_10_METHOD_STREAM_CONSUME_OK         0x04

#define AMQP_0_10_METHOD_STREAM_CANCEL             0x05

#define AMQP_0_10_METHOD_STREAM_PUBLISH            0x06

#define AMQP_0_10_METHOD_STREAM_RETURN             0x07

#define AMQP_0_10_METHOD_STREAM_DELIVER            0x08

/*  Private functions  */

static unsigned

dissect_amqp_0_9_field_value(tvbuff_t *tvb, packet_info *pinfo, int offset, unsigned length,

                             const char *name, proto_tree *field_table_tree);

static void

dissect_amqp_0_10_struct32(tvbuff_t *tvb, packet_info *pinfo, proto_item *ti);

static amqp_channel_t*

get_conversation_channel(conversation_t *conv, uint16_t channel_num);

static void

record_msg_delivery(tvbuff_t *tvb, packet_info *pinfo, uint16_t channel_num,

    uint64_t delivery_tag);

static void

record_msg_delivery_c(conversation_t *conv, amqp_channel_t *channel,

    tvbuff_t *tvb, packet_info *pinfo, uint64_t delivery_tag);

static void

record_delivery_ack(tvbuff_t *tvb, packet_info *pinfo, uint16_t channel_num,

    uint64_t delivery_tag, bool multiple);

static void

record_delivery_ack_c(conversation_t *conv, amqp_channel_t *channel,

    tvbuff_t *tvb, packet_info *pinfo, uint64_t delivery_tag, bool multiple);

static void

generate_msg_reference(tvbuff_t *tvb, packet_info *pinfo, proto_tree *prop_tree);

static void

generate_ack_reference(tvbuff_t *tvb, packet_info *pinfo, proto_tree *prop_tree);

/*  AMQP 0-10 type decoding information  */

typedef int (*type_formatter)(tvbuff_t *tvb,

                              unsigned offset,        /* In tvb where data starts */

                              unsigned length,        /* Length of data, if known */

                              const char **value); /* Receive formatted val */

struct amqp_typeinfo {

    uint8_t         typecode;   /* From AMQP 0-10 spec */

    const char     *amqp_typename;

    type_formatter  formatter;

    unsigned        known_size;

};

/*  AMQP 1-0 type decoding information  */

typedef int (*type_dissector)(tvbuff_t *tvb,

                              packet_info *pinfo,

                              unsigned offset,        /* In tvb where data starts */

                              unsigned length,        /* Length of data, if known */

                              proto_item *item,

                              int hf_amqp_type);

struct amqp1_typeinfo {

    uint8_t         typecode;   /* From AMQP 0-10 spec */

    const char     *amqp_typename;

    const int       ftype;

    unsigned        known_size;

    type_dissector  dissector;

    type_formatter  formatter;

};

struct amqp_synonym_types_t {

    const int *hf_none; /* Must be of type FT_NONE */

    const int *hf_uint; /* FT_UINT */

    const int *hf_str;  /* FT_STRING */

    const int *hf_bin;  /* FT_BYTES */

    const int *hf_guid; /* FT_GUID */

};

/*  struct for field interpreting format code (i.e. 0x70 for msg.header) to relevant hf_* variable

 *  (here hf_amqp_1_0_messageHeader). If the type is list, next 2 struct items specify how to

 *  interpret list items (in terms of hf_* variable)

 */

struct amqp_defined_types_t {

    const int format_code;

    int       *hf_amqp_type;

    uint32_t  hf_amqp_subtype_count;

    int * const *hf_amqp_subtypes;

};

/* functions for decoding 1.0 type and/or value */

static const struct amqp1_typeinfo* decode_fixed_type(uint8_t code);

static void

get_amqp_1_0_value_formatter(tvbuff_t *tvb,

                             packet_info *pinfo,

                             uint8_t code,

                             int offset,

                             int hf_amqp_type,

                             const char *name,

                             uint32_t hf_amqp_subtype_count,

                             int * const *hf_amqp_subtypes,

                             unsigned *length_size,

                             proto_item *item);

static unsigned

get_amqp_1_0_type_formatter(tvbuff_t *tvb,

                            int offset,

                            int *hf_amqp_type,

                            const char **name,

                            uint32_t *hf_amqp_subtype_count,

                            int * const **hf_amqp_subtypes,

                            unsigned *length_size);

static void

get_amqp_1_0_type_value_formatter(tvbuff_t *tvb,

                                  packet_info *pinfo,

                                  int offset,

                                  int hf_amqp_type,

                                  const char *name,

                                  unsigned *length_size,

                                  proto_item *item);

/* functions for decoding particular primitive types */

static int

dissect_amqp_1_0_fixed(tvbuff_t *tvb, packet_info *pinfo,

                       unsigned offset, unsigned length,

                       proto_item *item, int hf_amqp_type);

static int

dissect_amqp_1_0_variable(tvbuff_t *tvb, packet_info *pinfo,

                          unsigned offset, unsigned length,

                          proto_item *item, int hf_amqp_type);

static int

dissect_amqp_1_0_timestamp(tvbuff_t *tvb, packet_info *pinfo _U_,

                           unsigned offset, unsigned length,

                           proto_item *item, int hf_amqp_type);

static int

dissect_amqp_1_0_skip(tvbuff_t *tvb _U_, packet_info *pinfo _U_,

                      unsigned offset _U_, unsigned length _U_,

                      proto_item *item _U_, int hf_amqp_type _U_);

static int

dissect_amqp_1_0_zero(tvbuff_t *tvb, packet_info *pinfo,

                      unsigned offset, unsigned length _U_,

                      proto_item *item, int hf_amqp_type);

static int

dissect_amqp_1_0_true(tvbuff_t *tvb, packet_info *pinfo,

                      unsigned offset, unsigned length _U_,

                      proto_item *item, int hf_amqp_type);

static int

dissect_amqp_1_0_false(tvbuff_t *tvb, packet_info *pinfo,

                               unsigned offset, unsigned length _U_,

                               proto_item *item, int hf_amqp_type);

static int

format_amqp_1_0_null(tvbuff_t *tvb _U_,

                     unsigned offset _U_, unsigned length _U_,

                     const char **value);

static int

format_amqp_1_0_boolean_true(tvbuff_t *tvb, unsigned offset, unsigned length _U_,

                             const char **value);

static int

format_amqp_1_0_boolean_false(tvbuff_t *tvb, unsigned offset, unsigned length _U_,

                              const char **value);

static int

format_amqp_1_0_boolean(tvbuff_t *tvb, unsigned offset, unsigned length _U_,

                        const char **value);

static int

format_amqp_1_0_uint(tvbuff_t *tvb, unsigned offset, unsigned length,

                     const char **value);

static int

format_amqp_1_0_int(tvbuff_t *tvb, unsigned offset, unsigned length,

                    const char **value);

static int

format_amqp_1_0_float(tvbuff_t *tvb, unsigned offset, unsigned length _U_,

                      const char **value);

static int

format_amqp_1_0_double(tvbuff_t *tvb, unsigned offset, unsigned length _U_,

                       const char **value);

static int

format_amqp_1_0_decimal(tvbuff_t *tvb _U_, unsigned offset _U_, unsigned length,

                        const char **value);

static int

format_amqp_1_0_char(tvbuff_t *tvb, unsigned offset, unsigned length _U_,

                     const char **value);

static int

format_amqp_1_0_timestamp(tvbuff_t *tvb, unsigned offset, unsigned length _U_,

                          const char **value);

static int

format_amqp_1_0_uuid(tvbuff_t *tvb, unsigned offset, unsigned length _U_,

                     const char **value);

static int

format_amqp_1_0_bin(tvbuff_t *tvb, unsigned offset, unsigned length,

                    const char **value);

static int

format_amqp_1_0_str(tvbuff_t *tvb, unsigned offset, unsigned length,

                    const char **value);

static int

format_amqp_1_0_symbol(tvbuff_t *tvb, unsigned offset, unsigned length,

                       const char **value);

static bool

get_amqp_0_10_type_formatter(uint8_t code,

                             const char **name,

                             type_formatter *decoder,

                             unsigned *length_size);

static int

format_amqp_0_10_bin(tvbuff_t *tvb,

                     unsigned offset, unsigned length,

                     const char **value);

static int

format_amqp_0_10_int(tvbuff_t *tvb,

                     unsigned offset, unsigned length,

                     const char **value);

static int

format_amqp_0_10_uint(tvbuff_t *tvb,

                      unsigned offset, unsigned length,

                      const char **value);

static int

format_amqp_0_10_char(tvbuff_t *tvb,

                      unsigned offset, unsigned length,

                      const char **value);

static int

format_amqp_0_10_boolean(tvbuff_t *tvb,

                         unsigned offset, unsigned length,

                         const char **value);

static int

format_amqp_0_10_vbin(tvbuff_t *tvb,

                      unsigned offset, unsigned length,

                      const char **value);

static int

format_amqp_0_10_str(tvbuff_t *tvb,

                     unsigned offset, unsigned length,

                     const char **value);

static void

format_amqp_0_10_sequence_set(tvbuff_t *tvb, unsigned offset, unsigned length,

                              proto_item *item);

/*  Various handles  */

static int proto_amqp;

static int proto_amqpv0_9;

static int proto_amqpv0_10;

static int proto_amqpv1_0;

/* 1.0 handles */

static int hf_amqp_1_0_size;

static int hf_amqp_1_0_doff;

static int hf_amqp_1_0_type;

static int hf_amqp_1_0_containerId;

static int hf_amqp_1_0_hostname;

static int hf_amqp_1_0_maxFrameSize;

static int hf_amqp_1_0_channelMax;

static int hf_amqp_1_0_idleTimeOut;

static int hf_amqp_1_0_outgoingLocales;

static int hf_amqp_1_0_incomingLocales;

static int hf_amqp_1_0_offeredCapabilities;

static int hf_amqp_1_0_desiredCapabilities;

static int hf_amqp_1_0_properties;

static int hf_amqp_1_0_remoteChannel;

static int hf_amqp_1_0_nextOutgoingId;

static int hf_amqp_1_0_incomingWindow;

static int hf_amqp_1_0_outgoingWindow;

static int hf_amqp_1_0_handleMax;

static int hf_amqp_1_0_name;

static int hf_amqp_1_0_handle;

static int hf_amqp_1_0_role;

static int hf_amqp_1_0_sndSettleMode;

static int hf_amqp_1_0_rcvSettleMode;

static int hf_amqp_1_0_source;

static int hf_amqp_1_0_target;

static int hf_amqp_1_0_deleteOnClose;

static int hf_amqp_1_0_deleteOnNoLinks;

static int hf_amqp_1_0_deleteOnNoMessages;

static int hf_amqp_1_0_deleteOnNoLinksOrMessages;

static int hf_amqp_1_0_coordinator;

static int hf_amqp_1_0_declare;

static int hf_amqp_1_0_globalId;

static int hf_amqp_1_0_discharge;

static int hf_amqp_1_0_txnId;

static int hf_amqp_1_0_fail;

static int hf_amqp_1_0_declared;

static int hf_amqp_1_0_transactionalState;

static int hf_amqp_1_0_outcome;

static int hf_amqp_1_0_unsettled;

static int hf_amqp_1_0_incompleteUnsettled;

static int hf_amqp_1_0_initialDeliveryCount;

static int hf_amqp_1_0_maxMessageSize;

static int hf_amqp_1_0_nextIncomingId;

static int hf_amqp_1_0_deliveryCount;

static int hf_amqp_1_0_sectionNumber;

static int hf_amqp_1_0_sectionOffset;

static int hf_amqp_1_0_deliveryFailed;

static int hf_amqp_1_0_undeliverableHere;

static int hf_amqp_1_0_linkCredit;

static int hf_amqp_1_0_available;

static int hf_amqp_1_0_drain;

static int hf_amqp_1_0_echo;

static int hf_amqp_1_0_deliveryId;

static int hf_amqp_1_0_deliveryTag;

static int hf_amqp_1_0_messageFormat;

static int hf_amqp_1_0_settled;

static int hf_amqp_1_0_more;

static int hf_amqp_1_0_state;

static int hf_amqp_1_0_resume;

static int hf_amqp_1_0_aborted;

static int hf_amqp_1_0_batchable;

static int hf_amqp_1_0_first;

static int hf_amqp_1_0_last;

static int hf_amqp_1_0_closed;

static int hf_amqp_1_0_amqp_performative;

static int hf_amqp_1_0_error;

static int hf_amqp_1_0_messageHeader;

static int hf_amqp_1_0_deliveryAnnotations;

static int hf_amqp_1_0_messageAnnotations;

static int hf_amqp_1_0_messageProperties;

static int hf_amqp_1_0_applicationProperties;

static int hf_amqp_1_0_data;

static int hf_amqp_1_0_amqp_sequence;

static int hf_amqp_1_0_amqp_value;

static int hf_amqp_1_0_footer;

static int hf_amqp_1_0_received;

static int hf_amqp_1_0_accepted;

static int hf_amqp_1_0_rejected;

static int hf_amqp_1_0_released;

static int hf_amqp_1_0_modified;

static int hf_amqp_1_0_condition;

static int hf_amqp_1_0_description;

static int hf_amqp_1_0_info;

static int hf_amqp_1_0_address;

static int hf_amqp_1_0_durable;

static int hf_amqp_1_0_terminusDurable;

static int hf_amqp_1_0_priority;

static int hf_amqp_1_0_ttl;

static int hf_amqp_1_0_firstAcquirer;

static int hf_amqp_1_0_expiryPolicy;

static int hf_amqp_1_0_timeout;

static int hf_amqp_1_0_dynamic;

static int hf_amqp_1_0_dynamicNodeProperties;

static int hf_amqp_1_0_distributionMode;

static int hf_amqp_1_0_filter;

static int hf_amqp_1_0_defaultOutcome;

static int hf_amqp_1_0_outcomes;

static int hf_amqp_1_0_capabilities;

static int hf_amqp_1_0_messageId;

static int hf_amqp_1_0_userId;

static int hf_amqp_1_0_to;

static int hf_amqp_1_0_subject;

static int hf_amqp_1_0_replyTo;

static int hf_amqp_1_0_correlationId;

static int hf_amqp_1_0_contentType;

static int hf_amqp_1_0_contentEncoding;

static int hf_amqp_1_0_absoluteExpiryTime;

static int hf_amqp_1_0_creationTime;

static int hf_amqp_1_0_groupId;

static int hf_amqp_1_0_groupSequence;

static int hf_amqp_1_0_replyToGroupId;

static int hf_amqp_1_0_sasl_method;

static int hf_amqp_1_0_mechanisms;

static int hf_amqp_1_0_mechanism;

static int hf_amqp_1_0_initResponse;

static int hf_amqp_1_0_saslChallenge;

static int hf_amqp_1_0_saslResponse;

static int hf_amqp_1_0_saslCode;

static int hf_amqp_1_0_saslAdditionalData;

static int hf_amqp_1_0_list;

static int hf_amqp_1_0_map;

/* variables for variant sub-types (see amqp_synonym_types)

 * - fields of type="*" can be of any type

 * - fields with multiple="true" may contain the type or an array */

static int hf_amqp_1_0_outgoingLocales_sym;

static int hf_amqp_1_0_incomingLocales_sym;

static int hf_amqp_1_0_offeredCapabilities_sym;

static int hf_amqp_1_0_desiredCapabilities_sym;

static int hf_amqp_1_0_address_str;

static int hf_amqp_1_0_source_str;

static int hf_amqp_1_0_target_str;

static int hf_amqp_1_0_outcomes_sym;

static int hf_amqp_1_0_capabilities_sym;

static int hf_amqp_1_0_messageId_uint;

static int hf_amqp_1_0_messageId_str;

static int hf_amqp_1_0_messageId_bin;

static int hf_amqp_1_0_messageId_uuid;

static int hf_amqp_1_0_correlationId_uint;

static int hf_amqp_1_0_correlationId_str;

static int hf_amqp_1_0_correlationId_bin;

static int hf_amqp_1_0_correlationId_uuid;

static int hf_amqp_1_0_to_str;

static int hf_amqp_1_0_replyTo_str;

static int hf_amqp_1_0_mechanisms_sym;

/* Several field can be of multiple types. To distinguish it among hf_amqp_1_0_* variables,

 * table below "translates" original hf_amqp_1_0_* variable to the type-specific one.

 * Each row contains synonym fields for {FT_NONE, FT_UINT, FT_STRING, FT_BYTES, FT_GUID}

 * NULL indicates no synonym of a given type

 * FT_NONE field must be always present

 */

static const struct amqp_synonym_types_t amqp_synonym_types[] = {

    {&hf_amqp_1_0_outgoingLocales, NULL, &hf_amqp_1_0_outgoingLocales_sym, NULL, NULL},

    {&hf_amqp_1_0_incomingLocales, NULL, &hf_amqp_1_0_incomingLocales_sym, NULL, NULL},

    {&hf_amqp_1_0_offeredCapabilities, NULL, &hf_amqp_1_0_offeredCapabilities_sym, NULL, NULL},

    {&hf_amqp_1_0_desiredCapabilities, NULL, &hf_amqp_1_0_desiredCapabilities_sym, NULL, NULL},

    {&hf_amqp_1_0_address, NULL, &hf_amqp_1_0_address_str, NULL, NULL},

    {&hf_amqp_1_0_source, NULL, &hf_amqp_1_0_source_str, NULL, NULL},

    {&hf_amqp_1_0_target, NULL, &hf_amqp_1_0_target_str, NULL, NULL},

    {&hf_amqp_1_0_outcomes, NULL, &hf_amqp_1_0_outcomes_sym, NULL, NULL},

    {&hf_amqp_1_0_capabilities, NULL, &hf_amqp_1_0_capabilities_sym, NULL, NULL},

    {&hf_amqp_1_0_messageId, &hf_amqp_1_0_messageId_uint, &hf_amqp_1_0_messageId_str, &hf_amqp_1_0_messageId_bin, &hf_amqp_1_0_messageId_uuid},

    {&hf_amqp_1_0_messageId, &hf_amqp_1_0_messageId_uint, &hf_amqp_1_0_messageId_str, &hf_amqp_1_0_messageId_bin, &hf_amqp_1_0_messageId_uuid},

    {&hf_amqp_1_0_correlationId, &hf_amqp_1_0_correlationId_uint, &hf_amqp_1_0_correlationId_str, &hf_amqp_1_0_correlationId_bin, &hf_amqp_1_0_correlationId_uuid},

    {&hf_amqp_1_0_to, NULL, &hf_amqp_1_0_to_str, NULL, NULL},

    {&hf_amqp_1_0_replyTo, NULL, &hf_amqp_1_0_replyTo_str, NULL, NULL},

    {&hf_amqp_1_0_mechanisms, NULL, &hf_amqp_1_0_mechanisms_sym, NULL, NULL},

    {NULL, NULL, NULL, NULL, NULL}

};

/* fields with hf_* types for list items;

 * i.e. sasl.init method has 3 arguments in a list (mechanism, init.response, hostname)

 * so when dissecting sasl.init arguments list, identify the list items with

 * corresponding hf_* variable */

static int * const amqp_1_0_sasl_mechanisms_items[] = { &hf_amqp_1_0_mechanisms };

static int * const amqp_1_0_sasl_init_items[] = { &hf_amqp_1_0_mechanism,

                                             &hf_amqp_1_0_initResponse,

                                             &hf_amqp_1_0_hostname };

static int * const amqp_1_0_sasl_challenge_items[] = { &hf_amqp_1_0_saslChallenge };

static int * const amqp_1_0_sasl_response_items[] = { &hf_amqp_1_0_saslResponse };

static int * const amqp_1_0_sasl_outcome_items[] = { &hf_amqp_1_0_saslCode,

                                                &hf_amqp_1_0_saslAdditionalData };

static int * const amqp_1_0_amqp_open_items[] = { &hf_amqp_1_0_containerId,

                                             &hf_amqp_1_0_hostname,

                                             &hf_amqp_1_0_maxFrameSize,

                                             &hf_amqp_1_0_channelMax,

                                             &hf_amqp_1_0_idleTimeOut,

                                             &hf_amqp_1_0_outgoingLocales,

                                             &hf_amqp_1_0_incomingLocales,

                                             &hf_amqp_1_0_offeredCapabilities,

                                             &hf_amqp_1_0_desiredCapabilities,

                                             &hf_amqp_1_0_properties };

static int * const amqp_1_0_amqp_begin_items[] = { &hf_amqp_1_0_remoteChannel,

                                              &hf_amqp_1_0_nextOutgoingId,

                                              &hf_amqp_1_0_incomingWindow,

                                              &hf_amqp_1_0_outgoingWindow,

                                              &hf_amqp_1_0_handleMax,

                                              &hf_amqp_1_0_offeredCapabilities,

                                              &hf_amqp_1_0_desiredCapabilities,

                                              &hf_amqp_1_0_properties };

static int * const amqp_1_0_amqp_attach_items[] = { &hf_amqp_1_0_name,

                                               &hf_amqp_1_0_handle,

                                               &hf_amqp_1_0_role,

                                               &hf_amqp_1_0_sndSettleMode,

                                               &hf_amqp_1_0_rcvSettleMode,

                                               &hf_amqp_1_0_source,

                                               &hf_amqp_1_0_target,

                                               &hf_amqp_1_0_unsettled,

                                               &hf_amqp_1_0_incompleteUnsettled,

                                               &hf_amqp_1_0_initialDeliveryCount,

                                               &hf_amqp_1_0_maxMessageSize,

                                               &hf_amqp_1_0_offeredCapabilities,

                                               &hf_amqp_1_0_desiredCapabilities,

                                               &hf_amqp_1_0_properties };

static int * const amqp_1_0_amqp_flow_items[] = { &hf_amqp_1_0_nextIncomingId,

                                             &hf_amqp_1_0_incomingWindow,

                                             &hf_amqp_1_0_nextOutgoingId,

                                             &hf_amqp_1_0_outgoingWindow,

                                             &hf_amqp_1_0_handle,

                                             &hf_amqp_1_0_deliveryCount,

                                             &hf_amqp_1_0_linkCredit,

                                             &hf_amqp_1_0_available,

                                             &hf_amqp_1_0_drain,

                                             &hf_amqp_1_0_echo,

                                             &hf_amqp_1_0_properties };

static int * const amqp_1_0_amqp_transfer_items[] = { &hf_amqp_1_0_handle,

                                                 &hf_amqp_1_0_deliveryId,

                                                 &hf_amqp_1_0_deliveryTag,

                                                 &hf_amqp_1_0_messageFormat,

                                                 &hf_amqp_1_0_settled,

                                                 &hf_amqp_1_0_more,

                                                 &hf_amqp_1_0_rcvSettleMode,

                                                 &hf_amqp_1_0_state,

                                                 &hf_amqp_1_0_resume,

                                                 &hf_amqp_1_0_aborted,

                                                 &hf_amqp_1_0_batchable };

static int * const amqp_1_0_amqp_disposition_items[] = { &hf_amqp_1_0_role,

                                                    &hf_amqp_1_0_first,

                                                    &hf_amqp_1_0_last,

                                                    &hf_amqp_1_0_settled,

                                                    &hf_amqp_1_0_state,

                                                    &hf_amqp_1_0_batchable };

static int * const amqp_1_0_amqp_detach_items[] = { &hf_amqp_1_0_handle,

                                               &hf_amqp_1_0_closed,

                                               &hf_amqp_1_0_error };

static int * const amqp_1_0_amqp_end_items[] = { &hf_amqp_1_0_error };

static int * const amqp_1_0_amqp_close_items[] = { &hf_amqp_1_0_error };

static int * const amqp_1_0_error_items[] = { &hf_amqp_1_0_condition,

                                         &hf_amqp_1_0_description,

                                         &hf_amqp_1_0_info };

static int * const amqp_1_0_messageHeader_items[] = { &hf_amqp_1_0_durable,

                                                 &hf_amqp_1_0_priority,

                                                 &hf_amqp_1_0_ttl,

                                                 &hf_amqp_1_0_firstAcquirer,

                                                 &hf_amqp_1_0_deliveryCount };

static int * const amqp_1_0_received_items[] = { &hf_amqp_1_0_sectionNumber,

                                            &hf_amqp_1_0_sectionOffset };

static int * const amqp_1_0_rejected_items[] = { &hf_amqp_1_0_error };

static int * const amqp_1_0_modified_items[] = { &hf_amqp_1_0_deliveryFailed,

                                            &hf_amqp_1_0_undeliverableHere,

                                            &hf_amqp_1_0_messageAnnotations };

static int * const amqp_1_0_source_items[] = { &hf_amqp_1_0_address,

                                          &hf_amqp_1_0_terminusDurable,

                                          &hf_amqp_1_0_expiryPolicy,

                                          &hf_amqp_1_0_timeout,

                                          &hf_amqp_1_0_dynamic,

                                          &hf_amqp_1_0_dynamicNodeProperties,

                                          &hf_amqp_1_0_distributionMode,

                                          &hf_amqp_1_0_filter,

                                          &hf_amqp_1_0_defaultOutcome,

                                          &hf_amqp_1_0_outcomes,

                                          &hf_amqp_1_0_capabilities };

static int * const amqp_1_0_target_items[] = { &hf_amqp_1_0_address,

                                          &hf_amqp_1_0_terminusDurable,

                                          &hf_amqp_1_0_expiryPolicy,

                                          &hf_amqp_1_0_timeout,

                                          &hf_amqp_1_0_dynamic,

                                          &hf_amqp_1_0_dynamicNodeProperties,

                                          &hf_amqp_1_0_capabilities };

static int * const amqp_1_0_messageProperties_items[] = { &hf_amqp_1_0_messageId,

                                                     &hf_amqp_1_0_userId,

                                                     &hf_amqp_1_0_to,

                                                     &hf_amqp_1_0_subject,

                                                     &hf_amqp_1_0_replyTo,

                                                     &hf_amqp_1_0_correlationId,

                                                     &hf_amqp_1_0_contentType,

                                                     &hf_amqp_1_0_contentEncoding,

                                                     &hf_amqp_1_0_absoluteExpiryTime,

                                                     &hf_amqp_1_0_creationTime,

                                                     &hf_amqp_1_0_groupId,

                                                     &hf_amqp_1_0_groupSequence,

                                                     &hf_amqp_1_0_replyToGroupId };

static int * const amqp_1_0_coordinator_items[] = { &hf_amqp_1_0_capabilities };

static int * const amqp_1_0_declare_items[] = { &hf_amqp_1_0_globalId };

static int * const amqp_1_0_discharge_items[] = { &hf_amqp_1_0_txnId,

                                             &hf_amqp_1_0_fail };

static int * const amqp_1_0_declared_items[] = { &hf_amqp_1_0_txnId };

static int * const amqp_1_0_transactionalState_items[] = { &hf_amqp_1_0_txnId,

                                                      &hf_amqp_1_0_outcome };

/* 0-10 handles */

static int hf_amqp_0_10_format;

static int hf_amqp_0_10_position;

static int hf_amqp_0_10_type;

static int hf_amqp_0_10_size;

static int hf_amqp_0_10_track;

static int hf_amqp_0_10_class;

static int hf_amqp_0_10_connection_method;

static int hf_amqp_0_10_session_method;

static int hf_amqp_0_10_execution_method;

static int hf_amqp_0_10_message_method;

static int hf_amqp_0_10_tx_method;

static int hf_amqp_0_10_dtx_method;

static int hf_amqp_0_10_exchange_method;

static int hf_amqp_0_10_queue_method;

static int hf_amqp_0_10_file_method;

static int hf_amqp_0_10_stream_method;

static int hf_amqp_0_10_argument_packing_flags;

static int hf_amqp_0_10_session_header;

static int hf_amqp_0_10_session_header_sync;

static int hf_amqp_0_10_struct32_size;

static int hf_amqp_0_10_struct32;

static int hf_amqp_0_10_struct32_padding;

static int hf_amqp_0_10_struct32_class;

static int hf_amqp_0_10_struct32_struct;

static int hf_amqp_0_10_array_type;

static int hf_amqp_0_10_array_element_count;

static int hf_amqp_0_10_array_string;

static int hf_amqp_0_10_message_body;

static int hf_amqp_0_10_dtx_xid;

static int hf_amqp_0_10_dtx_xid_format;

static int hf_amqp_0_10_dtx_xid_global_id;

static int hf_amqp_0_10_dtx_xid_branch_id;

static int hf_amqp_0_10_struct_delivery_properties_discard_unroutable;

static int hf_amqp_0_10_struct_delivery_properties_immediate;

static int hf_amqp_0_10_struct_delivery_properties_redelivered;

static int hf_amqp_0_10_struct_delivery_properties_priority;

static int hf_amqp_0_10_struct_delivery_properties_mode;

static int hf_amqp_0_10_struct_delivery_properties_ttl;

static int hf_amqp_0_10_struct_delivery_properties_timestamp;

static int hf_amqp_0_10_struct_delivery_properties_expiration;

static int hf_amqp_0_10_struct_delivery_properties_exchange;

static int hf_amqp_0_10_struct_delivery_properties_routing_key;

static int hf_amqp_0_10_struct_delivery_properties_resume_ttl;

static int hf_amqp_0_10_struct_fragment_properties_first;

static int hf_amqp_0_10_struct_fragment_properties_last;

static int hf_amqp_0_10_struct_fragment_properties_size;

/* static int hf_amqp_0_10_struct_message_properties; */

static int hf_amqp_0_10_struct_message_properties_content_len;

static int hf_amqp_0_10_struct_message_properties_message_id;

static int hf_amqp_0_10_struct_message_properties_correlation;

static int hf_amqp_0_10_struct_message_properties_reply_to;

static int hf_amqp_0_10_struct_message_properties_content_type;