#include #include #include #include #include /* ntohl, htonl, ntohs, htons */ #include "amqp.h" #include "amqp_framing.h" #include "amqp_private.h" char const *amqp_method_name(amqp_method_number_t methodNumber) { switch (methodNumber) { case AMQP_CONNECTION_START_METHOD: return "AMQP_CONNECTION_START_METHOD"; case AMQP_CONNECTION_START_OK_METHOD: return "AMQP_CONNECTION_START_OK_METHOD"; case AMQP_CONNECTION_SECURE_METHOD: return "AMQP_CONNECTION_SECURE_METHOD"; case AMQP_CONNECTION_SECURE_OK_METHOD: return "AMQP_CONNECTION_SECURE_OK_METHOD"; case AMQP_CONNECTION_TUNE_METHOD: return "AMQP_CONNECTION_TUNE_METHOD"; case AMQP_CONNECTION_TUNE_OK_METHOD: return "AMQP_CONNECTION_TUNE_OK_METHOD"; case AMQP_CONNECTION_OPEN_METHOD: return "AMQP_CONNECTION_OPEN_METHOD"; case AMQP_CONNECTION_OPEN_OK_METHOD: return "AMQP_CONNECTION_OPEN_OK_METHOD"; case AMQP_CONNECTION_REDIRECT_METHOD: return "AMQP_CONNECTION_REDIRECT_METHOD"; case AMQP_CONNECTION_CLOSE_METHOD: return "AMQP_CONNECTION_CLOSE_METHOD"; case AMQP_CONNECTION_CLOSE_OK_METHOD: return "AMQP_CONNECTION_CLOSE_OK_METHOD"; case AMQP_CHANNEL_OPEN_METHOD: return "AMQP_CHANNEL_OPEN_METHOD"; case AMQP_CHANNEL_OPEN_OK_METHOD: return "AMQP_CHANNEL_OPEN_OK_METHOD"; case AMQP_CHANNEL_FLOW_METHOD: return "AMQP_CHANNEL_FLOW_METHOD"; case AMQP_CHANNEL_FLOW_OK_METHOD: return "AMQP_CHANNEL_FLOW_OK_METHOD"; case AMQP_CHANNEL_ALERT_METHOD: return "AMQP_CHANNEL_ALERT_METHOD"; case AMQP_CHANNEL_CLOSE_METHOD: return "AMQP_CHANNEL_CLOSE_METHOD"; case AMQP_CHANNEL_CLOSE_OK_METHOD: return "AMQP_CHANNEL_CLOSE_OK_METHOD"; case AMQP_ACCESS_REQUEST_METHOD: return "AMQP_ACCESS_REQUEST_METHOD"; case AMQP_ACCESS_REQUEST_OK_METHOD: return "AMQP_ACCESS_REQUEST_OK_METHOD"; case AMQP_EXCHANGE_DECLARE_METHOD: return "AMQP_EXCHANGE_DECLARE_METHOD"; case AMQP_EXCHANGE_DECLARE_OK_METHOD: return "AMQP_EXCHANGE_DECLARE_OK_METHOD"; case AMQP_EXCHANGE_DELETE_METHOD: return "AMQP_EXCHANGE_DELETE_METHOD"; case AMQP_EXCHANGE_DELETE_OK_METHOD: return "AMQP_EXCHANGE_DELETE_OK_METHOD"; case AMQP_QUEUE_DECLARE_METHOD: return "AMQP_QUEUE_DECLARE_METHOD"; case AMQP_QUEUE_DECLARE_OK_METHOD: return "AMQP_QUEUE_DECLARE_OK_METHOD"; case AMQP_QUEUE_BIND_METHOD: return "AMQP_QUEUE_BIND_METHOD"; case AMQP_QUEUE_BIND_OK_METHOD: return "AMQP_QUEUE_BIND_OK_METHOD"; case AMQP_QUEUE_PURGE_METHOD: return "AMQP_QUEUE_PURGE_METHOD"; case AMQP_QUEUE_PURGE_OK_METHOD: return "AMQP_QUEUE_PURGE_OK_METHOD"; case AMQP_QUEUE_DELETE_METHOD: return "AMQP_QUEUE_DELETE_METHOD"; case AMQP_QUEUE_DELETE_OK_METHOD: return "AMQP_QUEUE_DELETE_OK_METHOD"; case AMQP_QUEUE_UNBIND_METHOD: return "AMQP_QUEUE_UNBIND_METHOD"; case AMQP_QUEUE_UNBIND_OK_METHOD: return "AMQP_QUEUE_UNBIND_OK_METHOD"; case AMQP_BASIC_QOS_METHOD: return "AMQP_BASIC_QOS_METHOD"; case AMQP_BASIC_QOS_OK_METHOD: return "AMQP_BASIC_QOS_OK_METHOD"; case AMQP_BASIC_CONSUME_METHOD: return "AMQP_BASIC_CONSUME_METHOD"; case AMQP_BASIC_CONSUME_OK_METHOD: return "AMQP_BASIC_CONSUME_OK_METHOD"; case AMQP_BASIC_CANCEL_METHOD: return "AMQP_BASIC_CANCEL_METHOD"; case AMQP_BASIC_CANCEL_OK_METHOD: return "AMQP_BASIC_CANCEL_OK_METHOD"; case AMQP_BASIC_PUBLISH_METHOD: return "AMQP_BASIC_PUBLISH_METHOD"; case AMQP_BASIC_RETURN_METHOD: return "AMQP_BASIC_RETURN_METHOD"; case AMQP_BASIC_DELIVER_METHOD: return "AMQP_BASIC_DELIVER_METHOD"; case AMQP_BASIC_GET_METHOD: return "AMQP_BASIC_GET_METHOD"; case AMQP_BASIC_GET_OK_METHOD: return "AMQP_BASIC_GET_OK_METHOD"; case AMQP_BASIC_GET_EMPTY_METHOD: return "AMQP_BASIC_GET_EMPTY_METHOD"; case AMQP_BASIC_ACK_METHOD: return "AMQP_BASIC_ACK_METHOD"; case AMQP_BASIC_REJECT_METHOD: return "AMQP_BASIC_REJECT_METHOD"; case AMQP_BASIC_RECOVER_METHOD: return "AMQP_BASIC_RECOVER_METHOD"; case AMQP_FILE_QOS_METHOD: return "AMQP_FILE_QOS_METHOD"; case AMQP_FILE_QOS_OK_METHOD: return "AMQP_FILE_QOS_OK_METHOD"; case AMQP_FILE_CONSUME_METHOD: return "AMQP_FILE_CONSUME_METHOD"; case AMQP_FILE_CONSUME_OK_METHOD: return "AMQP_FILE_CONSUME_OK_METHOD"; case AMQP_FILE_CANCEL_METHOD: return "AMQP_FILE_CANCEL_METHOD"; case AMQP_FILE_CANCEL_OK_METHOD: return "AMQP_FILE_CANCEL_OK_METHOD"; case AMQP_FILE_OPEN_METHOD: return "AMQP_FILE_OPEN_METHOD"; case AMQP_FILE_OPEN_OK_METHOD: return "AMQP_FILE_OPEN_OK_METHOD"; case AMQP_FILE_STAGE_METHOD: return "AMQP_FILE_STAGE_METHOD"; case AMQP_FILE_PUBLISH_METHOD: return "AMQP_FILE_PUBLISH_METHOD"; case AMQP_FILE_RETURN_METHOD: return "AMQP_FILE_RETURN_METHOD"; case AMQP_FILE_DELIVER_METHOD: return "AMQP_FILE_DELIVER_METHOD"; case AMQP_FILE_ACK_METHOD: return "AMQP_FILE_ACK_METHOD"; case AMQP_FILE_REJECT_METHOD: return "AMQP_FILE_REJECT_METHOD"; case AMQP_STREAM_QOS_METHOD: return "AMQP_STREAM_QOS_METHOD"; case AMQP_STREAM_QOS_OK_METHOD: return "AMQP_STREAM_QOS_OK_METHOD"; case AMQP_STREAM_CONSUME_METHOD: return "AMQP_STREAM_CONSUME_METHOD"; case AMQP_STREAM_CONSUME_OK_METHOD: return "AMQP_STREAM_CONSUME_OK_METHOD"; case AMQP_STREAM_CANCEL_METHOD: return "AMQP_STREAM_CANCEL_METHOD"; case AMQP_STREAM_CANCEL_OK_METHOD: return "AMQP_STREAM_CANCEL_OK_METHOD"; case AMQP_STREAM_PUBLISH_METHOD: return "AMQP_STREAM_PUBLISH_METHOD"; case AMQP_STREAM_RETURN_METHOD: return "AMQP_STREAM_RETURN_METHOD"; case AMQP_STREAM_DELIVER_METHOD: return "AMQP_STREAM_DELIVER_METHOD"; case AMQP_TX_SELECT_METHOD: return "AMQP_TX_SELECT_METHOD"; case AMQP_TX_SELECT_OK_METHOD: return "AMQP_TX_SELECT_OK_METHOD"; case AMQP_TX_COMMIT_METHOD: return "AMQP_TX_COMMIT_METHOD"; case AMQP_TX_COMMIT_OK_METHOD: return "AMQP_TX_COMMIT_OK_METHOD"; case AMQP_TX_ROLLBACK_METHOD: return "AMQP_TX_ROLLBACK_METHOD"; case AMQP_TX_ROLLBACK_OK_METHOD: return "AMQP_TX_ROLLBACK_OK_METHOD"; case AMQP_DTX_SELECT_METHOD: return "AMQP_DTX_SELECT_METHOD"; case AMQP_DTX_SELECT_OK_METHOD: return "AMQP_DTX_SELECT_OK_METHOD"; case AMQP_DTX_START_METHOD: return "AMQP_DTX_START_METHOD"; case AMQP_DTX_START_OK_METHOD: return "AMQP_DTX_START_OK_METHOD"; case AMQP_TUNNEL_REQUEST_METHOD: return "AMQP_TUNNEL_REQUEST_METHOD"; case AMQP_TEST_INTEGER_METHOD: return "AMQP_TEST_INTEGER_METHOD"; case AMQP_TEST_INTEGER_OK_METHOD: return "AMQP_TEST_INTEGER_OK_METHOD"; case AMQP_TEST_STRING_METHOD: return "AMQP_TEST_STRING_METHOD"; case AMQP_TEST_STRING_OK_METHOD: return "AMQP_TEST_STRING_OK_METHOD"; case AMQP_TEST_TABLE_METHOD: return "AMQP_TEST_TABLE_METHOD"; case AMQP_TEST_TABLE_OK_METHOD: return "AMQP_TEST_TABLE_OK_METHOD"; case AMQP_TEST_CONTENT_METHOD: return "AMQP_TEST_CONTENT_METHOD"; case AMQP_TEST_CONTENT_OK_METHOD: return "AMQP_TEST_CONTENT_OK_METHOD"; default: return NULL; } } amqp_boolean_t amqp_method_has_content(amqp_method_number_t methodNumber) { switch (methodNumber) { case AMQP_BASIC_PUBLISH_METHOD: return 1; case AMQP_BASIC_RETURN_METHOD: return 1; case AMQP_BASIC_DELIVER_METHOD: return 1; case AMQP_BASIC_GET_OK_METHOD: return 1; case AMQP_FILE_STAGE_METHOD: return 1; case AMQP_FILE_RETURN_METHOD: return 1; case AMQP_STREAM_PUBLISH_METHOD: return 1; case AMQP_STREAM_RETURN_METHOD: return 1; case AMQP_STREAM_DELIVER_METHOD: return 1; case AMQP_TUNNEL_REQUEST_METHOD: return 1; case AMQP_TEST_CONTENT_METHOD: return 1; case AMQP_TEST_CONTENT_OK_METHOD: return 1; default: return 0; } } int amqp_decode_method(amqp_method_number_t methodNumber, amqp_pool_t *pool, amqp_bytes_t encoded, void **decoded) { int offset = 0; int table_result; uint8_t bit_buffer; switch (methodNumber) { case AMQP_CONNECTION_START_METHOD: { amqp_connection_start_t *m = (amqp_connection_start_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_start_t)); m->version_major = D_8(encoded, offset); offset++; m->version_minor = D_8(encoded, offset); offset++; table_result = amqp_decode_table(encoded, pool, &(m->server_properties), &offset); AMQP_CHECK_RESULT(table_result); m->mechanisms.len = D_32(encoded, offset); offset += 4; m->mechanisms.bytes = D_BYTES(encoded, offset, m->mechanisms.len); offset += m->mechanisms.len; m->locales.len = D_32(encoded, offset); offset += 4; m->locales.bytes = D_BYTES(encoded, offset, m->locales.len); offset += m->locales.len; *decoded = m; return 0; } case AMQP_CONNECTION_START_OK_METHOD: { amqp_connection_start_ok_t *m = (amqp_connection_start_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_start_ok_t)); table_result = amqp_decode_table(encoded, pool, &(m->client_properties), &offset); AMQP_CHECK_RESULT(table_result); m->mechanism.len = D_8(encoded, offset); offset++; m->mechanism.bytes = D_BYTES(encoded, offset, m->mechanism.len); offset += m->mechanism.len; m->response.len = D_32(encoded, offset); offset += 4; m->response.bytes = D_BYTES(encoded, offset, m->response.len); offset += m->response.len; m->locale.len = D_8(encoded, offset); offset++; m->locale.bytes = D_BYTES(encoded, offset, m->locale.len); offset += m->locale.len; *decoded = m; return 0; } case AMQP_CONNECTION_SECURE_METHOD: { amqp_connection_secure_t *m = (amqp_connection_secure_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_secure_t)); m->challenge.len = D_32(encoded, offset); offset += 4; m->challenge.bytes = D_BYTES(encoded, offset, m->challenge.len); offset += m->challenge.len; *decoded = m; return 0; } case AMQP_CONNECTION_SECURE_OK_METHOD: { amqp_connection_secure_ok_t *m = (amqp_connection_secure_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_secure_ok_t)); m->response.len = D_32(encoded, offset); offset += 4; m->response.bytes = D_BYTES(encoded, offset, m->response.len); offset += m->response.len; *decoded = m; return 0; } case AMQP_CONNECTION_TUNE_METHOD: { amqp_connection_tune_t *m = (amqp_connection_tune_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_tune_t)); m->channel_max = D_16(encoded, offset); offset += 2; m->frame_max = D_32(encoded, offset); offset += 4; m->heartbeat = D_16(encoded, offset); offset += 2; *decoded = m; return 0; } case AMQP_CONNECTION_TUNE_OK_METHOD: { amqp_connection_tune_ok_t *m = (amqp_connection_tune_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_tune_ok_t)); m->channel_max = D_16(encoded, offset); offset += 2; m->frame_max = D_32(encoded, offset); offset += 4; m->heartbeat = D_16(encoded, offset); offset += 2; *decoded = m; return 0; } case AMQP_CONNECTION_OPEN_METHOD: { amqp_connection_open_t *m = (amqp_connection_open_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_open_t)); m->virtual_host.len = D_8(encoded, offset); offset++; m->virtual_host.bytes = D_BYTES(encoded, offset, m->virtual_host.len); offset += m->virtual_host.len; m->capabilities.len = D_8(encoded, offset); offset++; m->capabilities.bytes = D_BYTES(encoded, offset, m->capabilities.len); offset += m->capabilities.len; bit_buffer = D_8(encoded, offset); offset++; m->insist = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_CONNECTION_OPEN_OK_METHOD: { amqp_connection_open_ok_t *m = (amqp_connection_open_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_open_ok_t)); m->known_hosts.len = D_8(encoded, offset); offset++; m->known_hosts.bytes = D_BYTES(encoded, offset, m->known_hosts.len); offset += m->known_hosts.len; *decoded = m; return 0; } case AMQP_CONNECTION_REDIRECT_METHOD: { amqp_connection_redirect_t *m = (amqp_connection_redirect_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_redirect_t)); m->host.len = D_8(encoded, offset); offset++; m->host.bytes = D_BYTES(encoded, offset, m->host.len); offset += m->host.len; m->known_hosts.len = D_8(encoded, offset); offset++; m->known_hosts.bytes = D_BYTES(encoded, offset, m->known_hosts.len); offset += m->known_hosts.len; *decoded = m; return 0; } case AMQP_CONNECTION_CLOSE_METHOD: { amqp_connection_close_t *m = (amqp_connection_close_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_close_t)); m->reply_code = D_16(encoded, offset); offset += 2; m->reply_text.len = D_8(encoded, offset); offset++; m->reply_text.bytes = D_BYTES(encoded, offset, m->reply_text.len); offset += m->reply_text.len; m->class_id = D_16(encoded, offset); offset += 2; m->method_id = D_16(encoded, offset); offset += 2; *decoded = m; return 0; } case AMQP_CONNECTION_CLOSE_OK_METHOD: { amqp_connection_close_ok_t *m = (amqp_connection_close_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_close_ok_t)); *decoded = m; return 0; } case AMQP_CHANNEL_OPEN_METHOD: { amqp_channel_open_t *m = (amqp_channel_open_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_open_t)); m->out_of_band.len = D_8(encoded, offset); offset++; m->out_of_band.bytes = D_BYTES(encoded, offset, m->out_of_band.len); offset += m->out_of_band.len; *decoded = m; return 0; } case AMQP_CHANNEL_OPEN_OK_METHOD: { amqp_channel_open_ok_t *m = (amqp_channel_open_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_open_ok_t)); *decoded = m; return 0; } case AMQP_CHANNEL_FLOW_METHOD: { amqp_channel_flow_t *m = (amqp_channel_flow_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_flow_t)); bit_buffer = D_8(encoded, offset); offset++; m->active = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_CHANNEL_FLOW_OK_METHOD: { amqp_channel_flow_ok_t *m = (amqp_channel_flow_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_flow_ok_t)); bit_buffer = D_8(encoded, offset); offset++; m->active = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_CHANNEL_ALERT_METHOD: { amqp_channel_alert_t *m = (amqp_channel_alert_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_alert_t)); m->reply_code = D_16(encoded, offset); offset += 2; m->reply_text.len = D_8(encoded, offset); offset++; m->reply_text.bytes = D_BYTES(encoded, offset, m->reply_text.len); offset += m->reply_text.len; table_result = amqp_decode_table(encoded, pool, &(m->details), &offset); AMQP_CHECK_RESULT(table_result); *decoded = m; return 0; } case AMQP_CHANNEL_CLOSE_METHOD: { amqp_channel_close_t *m = (amqp_channel_close_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_close_t)); m->reply_code = D_16(encoded, offset); offset += 2; m->reply_text.len = D_8(encoded, offset); offset++; m->reply_text.bytes = D_BYTES(encoded, offset, m->reply_text.len); offset += m->reply_text.len; m->class_id = D_16(encoded, offset); offset += 2; m->method_id = D_16(encoded, offset); offset += 2; *decoded = m; return 0; } case AMQP_CHANNEL_CLOSE_OK_METHOD: { amqp_channel_close_ok_t *m = (amqp_channel_close_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_close_ok_t)); *decoded = m; return 0; } case AMQP_ACCESS_REQUEST_METHOD: { amqp_access_request_t *m = (amqp_access_request_t *) amqp_pool_alloc(pool, sizeof(amqp_access_request_t)); m->realm.len = D_8(encoded, offset); offset++; m->realm.bytes = D_BYTES(encoded, offset, m->realm.len); offset += m->realm.len; bit_buffer = D_8(encoded, offset); offset++; m->exclusive = (bit_buffer & (1 << 0)) ? 1 : 0; m->passive = (bit_buffer & (1 << 1)) ? 1 : 0; m->active = (bit_buffer & (1 << 2)) ? 1 : 0; m->write = (bit_buffer & (1 << 3)) ? 1 : 0; m->read = (bit_buffer & (1 << 4)) ? 1 : 0; *decoded = m; return 0; } case AMQP_ACCESS_REQUEST_OK_METHOD: { amqp_access_request_ok_t *m = (amqp_access_request_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_access_request_ok_t)); m->ticket = D_16(encoded, offset); offset += 2; *decoded = m; return 0; } case AMQP_EXCHANGE_DECLARE_METHOD: { amqp_exchange_declare_t *m = (amqp_exchange_declare_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_declare_t)); m->ticket = D_16(encoded, offset); offset += 2; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->type.len = D_8(encoded, offset); offset++; m->type.bytes = D_BYTES(encoded, offset, m->type.len); offset += m->type.len; bit_buffer = D_8(encoded, offset); offset++; m->passive = (bit_buffer & (1 << 0)) ? 1 : 0; m->durable = (bit_buffer & (1 << 1)) ? 1 : 0; m->auto_delete = (bit_buffer & (1 << 2)) ? 1 : 0; m->internal = (bit_buffer & (1 << 3)) ? 1 : 0; m->nowait = (bit_buffer & (1 << 4)) ? 1 : 0; table_result = amqp_decode_table(encoded, pool, &(m->arguments), &offset); AMQP_CHECK_RESULT(table_result); *decoded = m; return 0; } case AMQP_EXCHANGE_DECLARE_OK_METHOD: { amqp_exchange_declare_ok_t *m = (amqp_exchange_declare_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_declare_ok_t)); *decoded = m; return 0; } case AMQP_EXCHANGE_DELETE_METHOD: { amqp_exchange_delete_t *m = (amqp_exchange_delete_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_delete_t)); m->ticket = D_16(encoded, offset); offset += 2; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; bit_buffer = D_8(encoded, offset); offset++; m->if_unused = (bit_buffer & (1 << 0)) ? 1 : 0; m->nowait = (bit_buffer & (1 << 1)) ? 1 : 0; *decoded = m; return 0; } case AMQP_EXCHANGE_DELETE_OK_METHOD: { amqp_exchange_delete_ok_t *m = (amqp_exchange_delete_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_delete_ok_t)); *decoded = m; return 0; } case AMQP_QUEUE_DECLARE_METHOD: { amqp_queue_declare_t *m = (amqp_queue_declare_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_declare_t)); m->ticket = D_16(encoded, offset); offset += 2; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; bit_buffer = D_8(encoded, offset); offset++; m->passive = (bit_buffer & (1 << 0)) ? 1 : 0; m->durable = (bit_buffer & (1 << 1)) ? 1 : 0; m->exclusive = (bit_buffer & (1 << 2)) ? 1 : 0; m->auto_delete = (bit_buffer & (1 << 3)) ? 1 : 0; m->nowait = (bit_buffer & (1 << 4)) ? 1 : 0; table_result = amqp_decode_table(encoded, pool, &(m->arguments), &offset); AMQP_CHECK_RESULT(table_result); *decoded = m; return 0; } case AMQP_QUEUE_DECLARE_OK_METHOD: { amqp_queue_declare_ok_t *m = (amqp_queue_declare_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_declare_ok_t)); m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; m->message_count = D_32(encoded, offset); offset += 4; m->consumer_count = D_32(encoded, offset); offset += 4; *decoded = m; return 0; } case AMQP_QUEUE_BIND_METHOD: { amqp_queue_bind_t *m = (amqp_queue_bind_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_bind_t)); m->ticket = D_16(encoded, offset); offset += 2; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; bit_buffer = D_8(encoded, offset); offset++; m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0; table_result = amqp_decode_table(encoded, pool, &(m->arguments), &offset); AMQP_CHECK_RESULT(table_result); *decoded = m; return 0; } case AMQP_QUEUE_BIND_OK_METHOD: { amqp_queue_bind_ok_t *m = (amqp_queue_bind_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_bind_ok_t)); *decoded = m; return 0; } case AMQP_QUEUE_PURGE_METHOD: { amqp_queue_purge_t *m = (amqp_queue_purge_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_purge_t)); m->ticket = D_16(encoded, offset); offset += 2; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; bit_buffer = D_8(encoded, offset); offset++; m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_QUEUE_PURGE_OK_METHOD: { amqp_queue_purge_ok_t *m = (amqp_queue_purge_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_purge_ok_t)); m->message_count = D_32(encoded, offset); offset += 4; *decoded = m; return 0; } case AMQP_QUEUE_DELETE_METHOD: { amqp_queue_delete_t *m = (amqp_queue_delete_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_delete_t)); m->ticket = D_16(encoded, offset); offset += 2; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; bit_buffer = D_8(encoded, offset); offset++; m->if_unused = (bit_buffer & (1 << 0)) ? 1 : 0; m->if_empty = (bit_buffer & (1 << 1)) ? 1 : 0; m->nowait = (bit_buffer & (1 << 2)) ? 1 : 0; *decoded = m; return 0; } case AMQP_QUEUE_DELETE_OK_METHOD: { amqp_queue_delete_ok_t *m = (amqp_queue_delete_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_delete_ok_t)); m->message_count = D_32(encoded, offset); offset += 4; *decoded = m; return 0; } case AMQP_QUEUE_UNBIND_METHOD: { amqp_queue_unbind_t *m = (amqp_queue_unbind_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_unbind_t)); m->ticket = D_16(encoded, offset); offset += 2; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; table_result = amqp_decode_table(encoded, pool, &(m->arguments), &offset); AMQP_CHECK_RESULT(table_result); *decoded = m; return 0; } case AMQP_QUEUE_UNBIND_OK_METHOD: { amqp_queue_unbind_ok_t *m = (amqp_queue_unbind_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_unbind_ok_t)); *decoded = m; return 0; } case AMQP_BASIC_QOS_METHOD: { amqp_basic_qos_t *m = (amqp_basic_qos_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_qos_t)); m->prefetch_size = D_32(encoded, offset); offset += 4; m->prefetch_count = D_16(encoded, offset); offset += 2; bit_buffer = D_8(encoded, offset); offset++; m->global = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_BASIC_QOS_OK_METHOD: { amqp_basic_qos_ok_t *m = (amqp_basic_qos_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_qos_ok_t)); *decoded = m; return 0; } case AMQP_BASIC_CONSUME_METHOD: { amqp_basic_consume_t *m = (amqp_basic_consume_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_consume_t)); m->ticket = D_16(encoded, offset); offset += 2; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; bit_buffer = D_8(encoded, offset); offset++; m->no_local = (bit_buffer & (1 << 0)) ? 1 : 0; m->no_ack = (bit_buffer & (1 << 1)) ? 1 : 0; m->exclusive = (bit_buffer & (1 << 2)) ? 1 : 0; m->nowait = (bit_buffer & (1 << 3)) ? 1 : 0; *decoded = m; return 0; } case AMQP_BASIC_CONSUME_OK_METHOD: { amqp_basic_consume_ok_t *m = (amqp_basic_consume_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_consume_ok_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; *decoded = m; return 0; } case AMQP_BASIC_CANCEL_METHOD: { amqp_basic_cancel_t *m = (amqp_basic_cancel_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_cancel_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; bit_buffer = D_8(encoded, offset); offset++; m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_BASIC_CANCEL_OK_METHOD: { amqp_basic_cancel_ok_t *m = (amqp_basic_cancel_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_cancel_ok_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; *decoded = m; return 0; } case AMQP_BASIC_PUBLISH_METHOD: { amqp_basic_publish_t *m = (amqp_basic_publish_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_publish_t)); m->ticket = D_16(encoded, offset); offset += 2; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; bit_buffer = D_8(encoded, offset); offset++; m->mandatory = (bit_buffer & (1 << 0)) ? 1 : 0; m->immediate = (bit_buffer & (1 << 1)) ? 1 : 0; *decoded = m; return 0; } case AMQP_BASIC_RETURN_METHOD: { amqp_basic_return_t *m = (amqp_basic_return_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_return_t)); m->reply_code = D_16(encoded, offset); offset += 2; m->reply_text.len = D_8(encoded, offset); offset++; m->reply_text.bytes = D_BYTES(encoded, offset, m->reply_text.len); offset += m->reply_text.len; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; *decoded = m; return 0; } case AMQP_BASIC_DELIVER_METHOD: { amqp_basic_deliver_t *m = (amqp_basic_deliver_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_deliver_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; m->delivery_tag = D_64(encoded, offset); offset += 8; bit_buffer = D_8(encoded, offset); offset++; m->redelivered = (bit_buffer & (1 << 0)) ? 1 : 0; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; *decoded = m; return 0; } case AMQP_BASIC_GET_METHOD: { amqp_basic_get_t *m = (amqp_basic_get_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_get_t)); m->ticket = D_16(encoded, offset); offset += 2; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; bit_buffer = D_8(encoded, offset); offset++; m->no_ack = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_BASIC_GET_OK_METHOD: { amqp_basic_get_ok_t *m = (amqp_basic_get_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_get_ok_t)); m->delivery_tag = D_64(encoded, offset); offset += 8; bit_buffer = D_8(encoded, offset); offset++; m->redelivered = (bit_buffer & (1 << 0)) ? 1 : 0; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; m->message_count = D_32(encoded, offset); offset += 4; *decoded = m; return 0; } case AMQP_BASIC_GET_EMPTY_METHOD: { amqp_basic_get_empty_t *m = (amqp_basic_get_empty_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_get_empty_t)); m->cluster_id.len = D_8(encoded, offset); offset++; m->cluster_id.bytes = D_BYTES(encoded, offset, m->cluster_id.len); offset += m->cluster_id.len; *decoded = m; return 0; } case AMQP_BASIC_ACK_METHOD: { amqp_basic_ack_t *m = (amqp_basic_ack_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_ack_t)); m->delivery_tag = D_64(encoded, offset); offset += 8; bit_buffer = D_8(encoded, offset); offset++; m->multiple = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_BASIC_REJECT_METHOD: { amqp_basic_reject_t *m = (amqp_basic_reject_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_reject_t)); m->delivery_tag = D_64(encoded, offset); offset += 8; bit_buffer = D_8(encoded, offset); offset++; m->requeue = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_BASIC_RECOVER_METHOD: { amqp_basic_recover_t *m = (amqp_basic_recover_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_recover_t)); bit_buffer = D_8(encoded, offset); offset++; m->requeue = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_FILE_QOS_METHOD: { amqp_file_qos_t *m = (amqp_file_qos_t *) amqp_pool_alloc(pool, sizeof(amqp_file_qos_t)); m->prefetch_size = D_32(encoded, offset); offset += 4; m->prefetch_count = D_16(encoded, offset); offset += 2; bit_buffer = D_8(encoded, offset); offset++; m->global = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_FILE_QOS_OK_METHOD: { amqp_file_qos_ok_t *m = (amqp_file_qos_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_file_qos_ok_t)); *decoded = m; return 0; } case AMQP_FILE_CONSUME_METHOD: { amqp_file_consume_t *m = (amqp_file_consume_t *) amqp_pool_alloc(pool, sizeof(amqp_file_consume_t)); m->ticket = D_16(encoded, offset); offset += 2; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; bit_buffer = D_8(encoded, offset); offset++; m->no_local = (bit_buffer & (1 << 0)) ? 1 : 0; m->no_ack = (bit_buffer & (1 << 1)) ? 1 : 0; m->exclusive = (bit_buffer & (1 << 2)) ? 1 : 0; m->nowait = (bit_buffer & (1 << 3)) ? 1 : 0; *decoded = m; return 0; } case AMQP_FILE_CONSUME_OK_METHOD: { amqp_file_consume_ok_t *m = (amqp_file_consume_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_file_consume_ok_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; *decoded = m; return 0; } case AMQP_FILE_CANCEL_METHOD: { amqp_file_cancel_t *m = (amqp_file_cancel_t *) amqp_pool_alloc(pool, sizeof(amqp_file_cancel_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; bit_buffer = D_8(encoded, offset); offset++; m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_FILE_CANCEL_OK_METHOD: { amqp_file_cancel_ok_t *m = (amqp_file_cancel_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_file_cancel_ok_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; *decoded = m; return 0; } case AMQP_FILE_OPEN_METHOD: { amqp_file_open_t *m = (amqp_file_open_t *) amqp_pool_alloc(pool, sizeof(amqp_file_open_t)); m->identifier.len = D_8(encoded, offset); offset++; m->identifier.bytes = D_BYTES(encoded, offset, m->identifier.len); offset += m->identifier.len; m->content_size = D_64(encoded, offset); offset += 8; *decoded = m; return 0; } case AMQP_FILE_OPEN_OK_METHOD: { amqp_file_open_ok_t *m = (amqp_file_open_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_file_open_ok_t)); m->staged_size = D_64(encoded, offset); offset += 8; *decoded = m; return 0; } case AMQP_FILE_STAGE_METHOD: { amqp_file_stage_t *m = (amqp_file_stage_t *) amqp_pool_alloc(pool, sizeof(amqp_file_stage_t)); *decoded = m; return 0; } case AMQP_FILE_PUBLISH_METHOD: { amqp_file_publish_t *m = (amqp_file_publish_t *) amqp_pool_alloc(pool, sizeof(amqp_file_publish_t)); m->ticket = D_16(encoded, offset); offset += 2; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; bit_buffer = D_8(encoded, offset); offset++; m->mandatory = (bit_buffer & (1 << 0)) ? 1 : 0; m->immediate = (bit_buffer & (1 << 1)) ? 1 : 0; m->identifier.len = D_8(encoded, offset); offset++; m->identifier.bytes = D_BYTES(encoded, offset, m->identifier.len); offset += m->identifier.len; *decoded = m; return 0; } case AMQP_FILE_RETURN_METHOD: { amqp_file_return_t *m = (amqp_file_return_t *) amqp_pool_alloc(pool, sizeof(amqp_file_return_t)); m->reply_code = D_16(encoded, offset); offset += 2; m->reply_text.len = D_8(encoded, offset); offset++; m->reply_text.bytes = D_BYTES(encoded, offset, m->reply_text.len); offset += m->reply_text.len; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; *decoded = m; return 0; } case AMQP_FILE_DELIVER_METHOD: { amqp_file_deliver_t *m = (amqp_file_deliver_t *) amqp_pool_alloc(pool, sizeof(amqp_file_deliver_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; m->delivery_tag = D_64(encoded, offset); offset += 8; bit_buffer = D_8(encoded, offset); offset++; m->redelivered = (bit_buffer & (1 << 0)) ? 1 : 0; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; m->identifier.len = D_8(encoded, offset); offset++; m->identifier.bytes = D_BYTES(encoded, offset, m->identifier.len); offset += m->identifier.len; *decoded = m; return 0; } case AMQP_FILE_ACK_METHOD: { amqp_file_ack_t *m = (amqp_file_ack_t *) amqp_pool_alloc(pool, sizeof(amqp_file_ack_t)); m->delivery_tag = D_64(encoded, offset); offset += 8; bit_buffer = D_8(encoded, offset); offset++; m->multiple = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_FILE_REJECT_METHOD: { amqp_file_reject_t *m = (amqp_file_reject_t *) amqp_pool_alloc(pool, sizeof(amqp_file_reject_t)); m->delivery_tag = D_64(encoded, offset); offset += 8; bit_buffer = D_8(encoded, offset); offset++; m->requeue = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_STREAM_QOS_METHOD: { amqp_stream_qos_t *m = (amqp_stream_qos_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_qos_t)); m->prefetch_size = D_32(encoded, offset); offset += 4; m->prefetch_count = D_16(encoded, offset); offset += 2; m->consume_rate = D_32(encoded, offset); offset += 4; bit_buffer = D_8(encoded, offset); offset++; m->global = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_STREAM_QOS_OK_METHOD: { amqp_stream_qos_ok_t *m = (amqp_stream_qos_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_qos_ok_t)); *decoded = m; return 0; } case AMQP_STREAM_CONSUME_METHOD: { amqp_stream_consume_t *m = (amqp_stream_consume_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_consume_t)); m->ticket = D_16(encoded, offset); offset += 2; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; bit_buffer = D_8(encoded, offset); offset++; m->no_local = (bit_buffer & (1 << 0)) ? 1 : 0; m->exclusive = (bit_buffer & (1 << 1)) ? 1 : 0; m->nowait = (bit_buffer & (1 << 2)) ? 1 : 0; *decoded = m; return 0; } case AMQP_STREAM_CONSUME_OK_METHOD: { amqp_stream_consume_ok_t *m = (amqp_stream_consume_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_consume_ok_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; *decoded = m; return 0; } case AMQP_STREAM_CANCEL_METHOD: { amqp_stream_cancel_t *m = (amqp_stream_cancel_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_cancel_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; bit_buffer = D_8(encoded, offset); offset++; m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0; *decoded = m; return 0; } case AMQP_STREAM_CANCEL_OK_METHOD: { amqp_stream_cancel_ok_t *m = (amqp_stream_cancel_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_cancel_ok_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; *decoded = m; return 0; } case AMQP_STREAM_PUBLISH_METHOD: { amqp_stream_publish_t *m = (amqp_stream_publish_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_publish_t)); m->ticket = D_16(encoded, offset); offset += 2; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; bit_buffer = D_8(encoded, offset); offset++; m->mandatory = (bit_buffer & (1 << 0)) ? 1 : 0; m->immediate = (bit_buffer & (1 << 1)) ? 1 : 0; *decoded = m; return 0; } case AMQP_STREAM_RETURN_METHOD: { amqp_stream_return_t *m = (amqp_stream_return_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_return_t)); m->reply_code = D_16(encoded, offset); offset += 2; m->reply_text.len = D_8(encoded, offset); offset++; m->reply_text.bytes = D_BYTES(encoded, offset, m->reply_text.len); offset += m->reply_text.len; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->routing_key.len = D_8(encoded, offset); offset++; m->routing_key.bytes = D_BYTES(encoded, offset, m->routing_key.len); offset += m->routing_key.len; *decoded = m; return 0; } case AMQP_STREAM_DELIVER_METHOD: { amqp_stream_deliver_t *m = (amqp_stream_deliver_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_deliver_t)); m->consumer_tag.len = D_8(encoded, offset); offset++; m->consumer_tag.bytes = D_BYTES(encoded, offset, m->consumer_tag.len); offset += m->consumer_tag.len; m->delivery_tag = D_64(encoded, offset); offset += 8; m->exchange.len = D_8(encoded, offset); offset++; m->exchange.bytes = D_BYTES(encoded, offset, m->exchange.len); offset += m->exchange.len; m->queue.len = D_8(encoded, offset); offset++; m->queue.bytes = D_BYTES(encoded, offset, m->queue.len); offset += m->queue.len; *decoded = m; return 0; } case AMQP_TX_SELECT_METHOD: { amqp_tx_select_t *m = (amqp_tx_select_t *) amqp_pool_alloc(pool, sizeof(amqp_tx_select_t)); *decoded = m; return 0; } case AMQP_TX_SELECT_OK_METHOD: { amqp_tx_select_ok_t *m = (amqp_tx_select_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_tx_select_ok_t)); *decoded = m; return 0; } case AMQP_TX_COMMIT_METHOD: { amqp_tx_commit_t *m = (amqp_tx_commit_t *) amqp_pool_alloc(pool, sizeof(amqp_tx_commit_t)); *decoded = m; return 0; } case AMQP_TX_COMMIT_OK_METHOD: { amqp_tx_commit_ok_t *m = (amqp_tx_commit_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_tx_commit_ok_t)); *decoded = m; return 0; } case AMQP_TX_ROLLBACK_METHOD: { amqp_tx_rollback_t *m = (amqp_tx_rollback_t *) amqp_pool_alloc(pool, sizeof(amqp_tx_rollback_t)); *decoded = m; return 0; } case AMQP_TX_ROLLBACK_OK_METHOD: { amqp_tx_rollback_ok_t *m = (amqp_tx_rollback_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_tx_rollback_ok_t)); *decoded = m; return 0; } case AMQP_DTX_SELECT_METHOD: { amqp_dtx_select_t *m = (amqp_dtx_select_t *) amqp_pool_alloc(pool, sizeof(amqp_dtx_select_t)); *decoded = m; return 0; } case AMQP_DTX_SELECT_OK_METHOD: { amqp_dtx_select_ok_t *m = (amqp_dtx_select_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_dtx_select_ok_t)); *decoded = m; return 0; } case AMQP_DTX_START_METHOD: { amqp_dtx_start_t *m = (amqp_dtx_start_t *) amqp_pool_alloc(pool, sizeof(amqp_dtx_start_t)); m->dtx_identifier.len = D_8(encoded, offset); offset++; m->dtx_identifier.bytes = D_BYTES(encoded, offset, m->dtx_identifier.len); offset += m->dtx_identifier.len; *decoded = m; return 0; } case AMQP_DTX_START_OK_METHOD: { amqp_dtx_start_ok_t *m = (amqp_dtx_start_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_dtx_start_ok_t)); *decoded = m; return 0; } case AMQP_TUNNEL_REQUEST_METHOD: { amqp_tunnel_request_t *m = (amqp_tunnel_request_t *) amqp_pool_alloc(pool, sizeof(amqp_tunnel_request_t)); table_result = amqp_decode_table(encoded, pool, &(m->meta_data), &offset); AMQP_CHECK_RESULT(table_result); *decoded = m; return 0; } case AMQP_TEST_INTEGER_METHOD: { amqp_test_integer_t *m = (amqp_test_integer_t *) amqp_pool_alloc(pool, sizeof(amqp_test_integer_t)); m->integer_1 = D_8(encoded, offset); offset++; m->integer_2 = D_16(encoded, offset); offset += 2; m->integer_3 = D_32(encoded, offset); offset += 4; m->integer_4 = D_64(encoded, offset); offset += 8; m->operation = D_8(encoded, offset); offset++; *decoded = m; return 0; } case AMQP_TEST_INTEGER_OK_METHOD: { amqp_test_integer_ok_t *m = (amqp_test_integer_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_test_integer_ok_t)); m->result = D_64(encoded, offset); offset += 8; *decoded = m; return 0; } case AMQP_TEST_STRING_METHOD: { amqp_test_string_t *m = (amqp_test_string_t *) amqp_pool_alloc(pool, sizeof(amqp_test_string_t)); m->string_1.len = D_8(encoded, offset); offset++; m->string_1.bytes = D_BYTES(encoded, offset, m->string_1.len); offset += m->string_1.len; m->string_2.len = D_32(encoded, offset); offset += 4; m->string_2.bytes = D_BYTES(encoded, offset, m->string_2.len); offset += m->string_2.len; m->operation = D_8(encoded, offset); offset++; *decoded = m; return 0; } case AMQP_TEST_STRING_OK_METHOD: { amqp_test_string_ok_t *m = (amqp_test_string_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_test_string_ok_t)); m->result.len = D_32(encoded, offset); offset += 4; m->result.bytes = D_BYTES(encoded, offset, m->result.len); offset += m->result.len; *decoded = m; return 0; } case AMQP_TEST_TABLE_METHOD: { amqp_test_table_t *m = (amqp_test_table_t *) amqp_pool_alloc(pool, sizeof(amqp_test_table_t)); table_result = amqp_decode_table(encoded, pool, &(m->table), &offset); AMQP_CHECK_RESULT(table_result); m->integer_op = D_8(encoded, offset); offset++; m->string_op = D_8(encoded, offset); offset++; *decoded = m; return 0; } case AMQP_TEST_TABLE_OK_METHOD: { amqp_test_table_ok_t *m = (amqp_test_table_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_test_table_ok_t)); m->integer_result = D_64(encoded, offset); offset += 8; m->string_result.len = D_32(encoded, offset); offset += 4; m->string_result.bytes = D_BYTES(encoded, offset, m->string_result.len); offset += m->string_result.len; *decoded = m; return 0; } case AMQP_TEST_CONTENT_METHOD: { amqp_test_content_t *m = (amqp_test_content_t *) amqp_pool_alloc(pool, sizeof(amqp_test_content_t)); *decoded = m; return 0; } case AMQP_TEST_CONTENT_OK_METHOD: { amqp_test_content_ok_t *m = (amqp_test_content_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_test_content_ok_t)); m->content_checksum = D_32(encoded, offset); offset += 4; *decoded = m; return 0; } default: return -ENOENT; } } int amqp_decode_properties(uint16_t class_id, amqp_pool_t *pool, amqp_bytes_t encoded, void **decoded) { int offset = 0; int table_result; amqp_flags_t flags = 0; int flagword_index = 0; amqp_flags_t partial_flags; do { partial_flags = D_16(encoded, offset); offset += 2; flags |= (partial_flags << (flagword_index * 16)); flagword_index++; } while (partial_flags & 1); switch (class_id) { case 10: { amqp_connection_properties_t *p = (amqp_connection_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_properties_t)); p->_flags = flags; *decoded = p; return 0; } case 20: { amqp_channel_properties_t *p = (amqp_channel_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_properties_t)); p->_flags = flags; *decoded = p; return 0; } case 30: { amqp_access_properties_t *p = (amqp_access_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_access_properties_t)); p->_flags = flags; *decoded = p; return 0; } case 40: { amqp_exchange_properties_t *p = (amqp_exchange_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_properties_t)); p->_flags = flags; *decoded = p; return 0; } case 50: { amqp_queue_properties_t *p = (amqp_queue_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_properties_t)); p->_flags = flags; *decoded = p; return 0; } case 60: { amqp_basic_properties_t *p = (amqp_basic_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_properties_t)); p->_flags = flags; if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { p->content_type.len = D_8(encoded, offset); offset++; p->content_type.bytes = D_BYTES(encoded, offset, p->content_type.len); offset += p->content_type.len; } if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) { p->content_encoding.len = D_8(encoded, offset); offset++; p->content_encoding.bytes = D_BYTES(encoded, offset, p->content_encoding.len); offset += p->content_encoding.len; } if (flags & AMQP_BASIC_HEADERS_FLAG) { table_result = amqp_decode_table(encoded, pool, &(p->headers), &offset); AMQP_CHECK_RESULT(table_result); } if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) { p->delivery_mode = D_8(encoded, offset); offset++; } if (flags & AMQP_BASIC_PRIORITY_FLAG) { p->priority = D_8(encoded, offset); offset++; } if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) { p->correlation_id.len = D_8(encoded, offset); offset++; p->correlation_id.bytes = D_BYTES(encoded, offset, p->correlation_id.len); offset += p->correlation_id.len; } if (flags & AMQP_BASIC_REPLY_TO_FLAG) { p->reply_to.len = D_8(encoded, offset); offset++; p->reply_to.bytes = D_BYTES(encoded, offset, p->reply_to.len); offset += p->reply_to.len; } if (flags & AMQP_BASIC_EXPIRATION_FLAG) { p->expiration.len = D_8(encoded, offset); offset++; p->expiration.bytes = D_BYTES(encoded, offset, p->expiration.len); offset += p->expiration.len; } if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) { p->message_id.len = D_8(encoded, offset); offset++; p->message_id.bytes = D_BYTES(encoded, offset, p->message_id.len); offset += p->message_id.len; } if (flags & AMQP_BASIC_TIMESTAMP_FLAG) { p->timestamp = D_64(encoded, offset); offset += 8; } if (flags & AMQP_BASIC_TYPE_FLAG) { p->type.len = D_8(encoded, offset); offset++; p->type.bytes = D_BYTES(encoded, offset, p->type.len); offset += p->type.len; } if (flags & AMQP_BASIC_USER_ID_FLAG) { p->user_id.len = D_8(encoded, offset); offset++; p->user_id.bytes = D_BYTES(encoded, offset, p->user_id.len); offset += p->user_id.len; } if (flags & AMQP_BASIC_APP_ID_FLAG) { p->app_id.len = D_8(encoded, offset); offset++; p->app_id.bytes = D_BYTES(encoded, offset, p->app_id.len); offset += p->app_id.len; } if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) { p->cluster_id.len = D_8(encoded, offset); offset++; p->cluster_id.bytes = D_BYTES(encoded, offset, p->cluster_id.len); offset += p->cluster_id.len; } *decoded = p; return 0; } case 70: { amqp_file_properties_t *p = (amqp_file_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_file_properties_t)); p->_flags = flags; if (flags & AMQP_FILE_CONTENT_TYPE_FLAG) { p->content_type.len = D_8(encoded, offset); offset++; p->content_type.bytes = D_BYTES(encoded, offset, p->content_type.len); offset += p->content_type.len; } if (flags & AMQP_FILE_CONTENT_ENCODING_FLAG) { p->content_encoding.len = D_8(encoded, offset); offset++; p->content_encoding.bytes = D_BYTES(encoded, offset, p->content_encoding.len); offset += p->content_encoding.len; } if (flags & AMQP_FILE_HEADERS_FLAG) { table_result = amqp_decode_table(encoded, pool, &(p->headers), &offset); AMQP_CHECK_RESULT(table_result); } if (flags & AMQP_FILE_PRIORITY_FLAG) { p->priority = D_8(encoded, offset); offset++; } if (flags & AMQP_FILE_REPLY_TO_FLAG) { p->reply_to.len = D_8(encoded, offset); offset++; p->reply_to.bytes = D_BYTES(encoded, offset, p->reply_to.len); offset += p->reply_to.len; } if (flags & AMQP_FILE_MESSAGE_ID_FLAG) { p->message_id.len = D_8(encoded, offset); offset++; p->message_id.bytes = D_BYTES(encoded, offset, p->message_id.len); offset += p->message_id.len; } if (flags & AMQP_FILE_FILENAME_FLAG) { p->filename.len = D_8(encoded, offset); offset++; p->filename.bytes = D_BYTES(encoded, offset, p->filename.len); offset += p->filename.len; } if (flags & AMQP_FILE_TIMESTAMP_FLAG) { p->timestamp = D_64(encoded, offset); offset += 8; } if (flags & AMQP_FILE_CLUSTER_ID_FLAG) { p->cluster_id.len = D_8(encoded, offset); offset++; p->cluster_id.bytes = D_BYTES(encoded, offset, p->cluster_id.len); offset += p->cluster_id.len; } *decoded = p; return 0; } case 80: { amqp_stream_properties_t *p = (amqp_stream_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_stream_properties_t)); p->_flags = flags; if (flags & AMQP_STREAM_CONTENT_TYPE_FLAG) { p->content_type.len = D_8(encoded, offset); offset++; p->content_type.bytes = D_BYTES(encoded, offset, p->content_type.len); offset += p->content_type.len; } if (flags & AMQP_STREAM_CONTENT_ENCODING_FLAG) { p->content_encoding.len = D_8(encoded, offset); offset++; p->content_encoding.bytes = D_BYTES(encoded, offset, p->content_encoding.len); offset += p->content_encoding.len; } if (flags & AMQP_STREAM_HEADERS_FLAG) { table_result = amqp_decode_table(encoded, pool, &(p->headers), &offset); AMQP_CHECK_RESULT(table_result); } if (flags & AMQP_STREAM_PRIORITY_FLAG) { p->priority = D_8(encoded, offset); offset++; } if (flags & AMQP_STREAM_TIMESTAMP_FLAG) { p->timestamp = D_64(encoded, offset); offset += 8; } *decoded = p; return 0; } case 90: { amqp_tx_properties_t *p = (amqp_tx_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_tx_properties_t)); p->_flags = flags; *decoded = p; return 0; } case 100: { amqp_dtx_properties_t *p = (amqp_dtx_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_dtx_properties_t)); p->_flags = flags; *decoded = p; return 0; } case 110: { amqp_tunnel_properties_t *p = (amqp_tunnel_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_tunnel_properties_t)); p->_flags = flags; if (flags & AMQP_TUNNEL_HEADERS_FLAG) { table_result = amqp_decode_table(encoded, pool, &(p->headers), &offset); AMQP_CHECK_RESULT(table_result); } if (flags & AMQP_TUNNEL_PROXY_NAME_FLAG) { p->proxy_name.len = D_8(encoded, offset); offset++; p->proxy_name.bytes = D_BYTES(encoded, offset, p->proxy_name.len); offset += p->proxy_name.len; } if (flags & AMQP_TUNNEL_DATA_NAME_FLAG) { p->data_name.len = D_8(encoded, offset); offset++; p->data_name.bytes = D_BYTES(encoded, offset, p->data_name.len); offset += p->data_name.len; } if (flags & AMQP_TUNNEL_DURABLE_FLAG) { p->durable = D_8(encoded, offset); offset++; } if (flags & AMQP_TUNNEL_BROADCAST_FLAG) { p->broadcast = D_8(encoded, offset); offset++; } *decoded = p; return 0; } case 120: { amqp_test_properties_t *p = (amqp_test_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_test_properties_t)); p->_flags = flags; *decoded = p; return 0; } default: return -ENOENT; } } int amqp_encode_method(amqp_method_number_t methodNumber, void *decoded, amqp_bytes_t encoded) { int offset = 0; int table_result; uint8_t bit_buffer; switch (methodNumber) { case AMQP_CONNECTION_START_METHOD: { amqp_connection_start_t *m = (amqp_connection_start_t *) decoded; E_8(encoded, offset, m->version_major); offset++; E_8(encoded, offset, m->version_minor); offset++; table_result = amqp_encode_table(encoded, &(m->server_properties), &offset); if (table_result < 0) return table_result; E_32(encoded, offset, m->mechanisms.len); offset += 4; E_BYTES(encoded, offset, m->mechanisms.len, m->mechanisms.bytes); offset += m->mechanisms.len; E_32(encoded, offset, m->locales.len); offset += 4; E_BYTES(encoded, offset, m->locales.len, m->locales.bytes); offset += m->locales.len; return offset; } case AMQP_CONNECTION_START_OK_METHOD: { amqp_connection_start_ok_t *m = (amqp_connection_start_ok_t *) decoded; table_result = amqp_encode_table(encoded, &(m->client_properties), &offset); if (table_result < 0) return table_result; E_8(encoded, offset, m->mechanism.len); offset++; E_BYTES(encoded, offset, m->mechanism.len, m->mechanism.bytes); offset += m->mechanism.len; E_32(encoded, offset, m->response.len); offset += 4; E_BYTES(encoded, offset, m->response.len, m->response.bytes); offset += m->response.len; E_8(encoded, offset, m->locale.len); offset++; E_BYTES(encoded, offset, m->locale.len, m->locale.bytes); offset += m->locale.len; return offset; } case AMQP_CONNECTION_SECURE_METHOD: { amqp_connection_secure_t *m = (amqp_connection_secure_t *) decoded; E_32(encoded, offset, m->challenge.len); offset += 4; E_BYTES(encoded, offset, m->challenge.len, m->challenge.bytes); offset += m->challenge.len; return offset; } case AMQP_CONNECTION_SECURE_OK_METHOD: { amqp_connection_secure_ok_t *m = (amqp_connection_secure_ok_t *) decoded; E_32(encoded, offset, m->response.len); offset += 4; E_BYTES(encoded, offset, m->response.len, m->response.bytes); offset += m->response.len; return offset; } case AMQP_CONNECTION_TUNE_METHOD: { amqp_connection_tune_t *m = (amqp_connection_tune_t *) decoded; E_16(encoded, offset, m->channel_max); offset += 2; E_32(encoded, offset, m->frame_max); offset += 4; E_16(encoded, offset, m->heartbeat); offset += 2; return offset; } case AMQP_CONNECTION_TUNE_OK_METHOD: { amqp_connection_tune_ok_t *m = (amqp_connection_tune_ok_t *) decoded; E_16(encoded, offset, m->channel_max); offset += 2; E_32(encoded, offset, m->frame_max); offset += 4; E_16(encoded, offset, m->heartbeat); offset += 2; return offset; } case AMQP_CONNECTION_OPEN_METHOD: { amqp_connection_open_t *m = (amqp_connection_open_t *) decoded; E_8(encoded, offset, m->virtual_host.len); offset++; E_BYTES(encoded, offset, m->virtual_host.len, m->virtual_host.bytes); offset += m->virtual_host.len; E_8(encoded, offset, m->capabilities.len); offset++; E_BYTES(encoded, offset, m->capabilities.len, m->capabilities.bytes); offset += m->capabilities.len; bit_buffer = 0; if (m->insist) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_CONNECTION_OPEN_OK_METHOD: { amqp_connection_open_ok_t *m = (amqp_connection_open_ok_t *) decoded; E_8(encoded, offset, m->known_hosts.len); offset++; E_BYTES(encoded, offset, m->known_hosts.len, m->known_hosts.bytes); offset += m->known_hosts.len; return offset; } case AMQP_CONNECTION_REDIRECT_METHOD: { amqp_connection_redirect_t *m = (amqp_connection_redirect_t *) decoded; E_8(encoded, offset, m->host.len); offset++; E_BYTES(encoded, offset, m->host.len, m->host.bytes); offset += m->host.len; E_8(encoded, offset, m->known_hosts.len); offset++; E_BYTES(encoded, offset, m->known_hosts.len, m->known_hosts.bytes); offset += m->known_hosts.len; return offset; } case AMQP_CONNECTION_CLOSE_METHOD: { amqp_connection_close_t *m = (amqp_connection_close_t *) decoded; E_16(encoded, offset, m->reply_code); offset += 2; E_8(encoded, offset, m->reply_text.len); offset++; E_BYTES(encoded, offset, m->reply_text.len, m->reply_text.bytes); offset += m->reply_text.len; E_16(encoded, offset, m->class_id); offset += 2; E_16(encoded, offset, m->method_id); offset += 2; return offset; } case AMQP_CONNECTION_CLOSE_OK_METHOD: { return offset; } case AMQP_CHANNEL_OPEN_METHOD: { amqp_channel_open_t *m = (amqp_channel_open_t *) decoded; E_8(encoded, offset, m->out_of_band.len); offset++; E_BYTES(encoded, offset, m->out_of_band.len, m->out_of_band.bytes); offset += m->out_of_band.len; return offset; } case AMQP_CHANNEL_OPEN_OK_METHOD: { return offset; } case AMQP_CHANNEL_FLOW_METHOD: { amqp_channel_flow_t *m = (amqp_channel_flow_t *) decoded; bit_buffer = 0; if (m->active) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_CHANNEL_FLOW_OK_METHOD: { amqp_channel_flow_ok_t *m = (amqp_channel_flow_ok_t *) decoded; bit_buffer = 0; if (m->active) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_CHANNEL_ALERT_METHOD: { amqp_channel_alert_t *m = (amqp_channel_alert_t *) decoded; E_16(encoded, offset, m->reply_code); offset += 2; E_8(encoded, offset, m->reply_text.len); offset++; E_BYTES(encoded, offset, m->reply_text.len, m->reply_text.bytes); offset += m->reply_text.len; table_result = amqp_encode_table(encoded, &(m->details), &offset); if (table_result < 0) return table_result; return offset; } case AMQP_CHANNEL_CLOSE_METHOD: { amqp_channel_close_t *m = (amqp_channel_close_t *) decoded; E_16(encoded, offset, m->reply_code); offset += 2; E_8(encoded, offset, m->reply_text.len); offset++; E_BYTES(encoded, offset, m->reply_text.len, m->reply_text.bytes); offset += m->reply_text.len; E_16(encoded, offset, m->class_id); offset += 2; E_16(encoded, offset, m->method_id); offset += 2; return offset; } case AMQP_CHANNEL_CLOSE_OK_METHOD: { return offset; } case AMQP_ACCESS_REQUEST_METHOD: { amqp_access_request_t *m = (amqp_access_request_t *) decoded; E_8(encoded, offset, m->realm.len); offset++; E_BYTES(encoded, offset, m->realm.len, m->realm.bytes); offset += m->realm.len; bit_buffer = 0; if (m->exclusive) { bit_buffer |= (1 << 0); } if (m->passive) { bit_buffer |= (1 << 1); } if (m->active) { bit_buffer |= (1 << 2); } if (m->write) { bit_buffer |= (1 << 3); } if (m->read) { bit_buffer |= (1 << 4); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_ACCESS_REQUEST_OK_METHOD: { amqp_access_request_ok_t *m = (amqp_access_request_ok_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; return offset; } case AMQP_EXCHANGE_DECLARE_METHOD: { amqp_exchange_declare_t *m = (amqp_exchange_declare_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->type.len); offset++; E_BYTES(encoded, offset, m->type.len, m->type.bytes); offset += m->type.len; bit_buffer = 0; if (m->passive) { bit_buffer |= (1 << 0); } if (m->durable) { bit_buffer |= (1 << 1); } if (m->auto_delete) { bit_buffer |= (1 << 2); } if (m->internal) { bit_buffer |= (1 << 3); } if (m->nowait) { bit_buffer |= (1 << 4); } E_8(encoded, offset, bit_buffer); offset++; table_result = amqp_encode_table(encoded, &(m->arguments), &offset); if (table_result < 0) return table_result; return offset; } case AMQP_EXCHANGE_DECLARE_OK_METHOD: { return offset; } case AMQP_EXCHANGE_DELETE_METHOD: { amqp_exchange_delete_t *m = (amqp_exchange_delete_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; bit_buffer = 0; if (m->if_unused) { bit_buffer |= (1 << 0); } if (m->nowait) { bit_buffer |= (1 << 1); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_EXCHANGE_DELETE_OK_METHOD: { return offset; } case AMQP_QUEUE_DECLARE_METHOD: { amqp_queue_declare_t *m = (amqp_queue_declare_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; bit_buffer = 0; if (m->passive) { bit_buffer |= (1 << 0); } if (m->durable) { bit_buffer |= (1 << 1); } if (m->exclusive) { bit_buffer |= (1 << 2); } if (m->auto_delete) { bit_buffer |= (1 << 3); } if (m->nowait) { bit_buffer |= (1 << 4); } E_8(encoded, offset, bit_buffer); offset++; table_result = amqp_encode_table(encoded, &(m->arguments), &offset); if (table_result < 0) return table_result; return offset; } case AMQP_QUEUE_DECLARE_OK_METHOD: { amqp_queue_declare_ok_t *m = (amqp_queue_declare_ok_t *) decoded; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; E_32(encoded, offset, m->message_count); offset += 4; E_32(encoded, offset, m->consumer_count); offset += 4; return offset; } case AMQP_QUEUE_BIND_METHOD: { amqp_queue_bind_t *m = (amqp_queue_bind_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; bit_buffer = 0; if (m->nowait) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; table_result = amqp_encode_table(encoded, &(m->arguments), &offset); if (table_result < 0) return table_result; return offset; } case AMQP_QUEUE_BIND_OK_METHOD: { return offset; } case AMQP_QUEUE_PURGE_METHOD: { amqp_queue_purge_t *m = (amqp_queue_purge_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; bit_buffer = 0; if (m->nowait) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_QUEUE_PURGE_OK_METHOD: { amqp_queue_purge_ok_t *m = (amqp_queue_purge_ok_t *) decoded; E_32(encoded, offset, m->message_count); offset += 4; return offset; } case AMQP_QUEUE_DELETE_METHOD: { amqp_queue_delete_t *m = (amqp_queue_delete_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; bit_buffer = 0; if (m->if_unused) { bit_buffer |= (1 << 0); } if (m->if_empty) { bit_buffer |= (1 << 1); } if (m->nowait) { bit_buffer |= (1 << 2); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_QUEUE_DELETE_OK_METHOD: { amqp_queue_delete_ok_t *m = (amqp_queue_delete_ok_t *) decoded; E_32(encoded, offset, m->message_count); offset += 4; return offset; } case AMQP_QUEUE_UNBIND_METHOD: { amqp_queue_unbind_t *m = (amqp_queue_unbind_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; table_result = amqp_encode_table(encoded, &(m->arguments), &offset); if (table_result < 0) return table_result; return offset; } case AMQP_QUEUE_UNBIND_OK_METHOD: { return offset; } case AMQP_BASIC_QOS_METHOD: { amqp_basic_qos_t *m = (amqp_basic_qos_t *) decoded; E_32(encoded, offset, m->prefetch_size); offset += 4; E_16(encoded, offset, m->prefetch_count); offset += 2; bit_buffer = 0; if (m->global) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_BASIC_QOS_OK_METHOD: { return offset; } case AMQP_BASIC_CONSUME_METHOD: { amqp_basic_consume_t *m = (amqp_basic_consume_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; bit_buffer = 0; if (m->no_local) { bit_buffer |= (1 << 0); } if (m->no_ack) { bit_buffer |= (1 << 1); } if (m->exclusive) { bit_buffer |= (1 << 2); } if (m->nowait) { bit_buffer |= (1 << 3); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_BASIC_CONSUME_OK_METHOD: { amqp_basic_consume_ok_t *m = (amqp_basic_consume_ok_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; return offset; } case AMQP_BASIC_CANCEL_METHOD: { amqp_basic_cancel_t *m = (amqp_basic_cancel_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; bit_buffer = 0; if (m->nowait) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_BASIC_CANCEL_OK_METHOD: { amqp_basic_cancel_ok_t *m = (amqp_basic_cancel_ok_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; return offset; } case AMQP_BASIC_PUBLISH_METHOD: { amqp_basic_publish_t *m = (amqp_basic_publish_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; bit_buffer = 0; if (m->mandatory) { bit_buffer |= (1 << 0); } if (m->immediate) { bit_buffer |= (1 << 1); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_BASIC_RETURN_METHOD: { amqp_basic_return_t *m = (amqp_basic_return_t *) decoded; E_16(encoded, offset, m->reply_code); offset += 2; E_8(encoded, offset, m->reply_text.len); offset++; E_BYTES(encoded, offset, m->reply_text.len, m->reply_text.bytes); offset += m->reply_text.len; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; return offset; } case AMQP_BASIC_DELIVER_METHOD: { amqp_basic_deliver_t *m = (amqp_basic_deliver_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; E_64(encoded, offset, m->delivery_tag); offset += 8; bit_buffer = 0; if (m->redelivered) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; return offset; } case AMQP_BASIC_GET_METHOD: { amqp_basic_get_t *m = (amqp_basic_get_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; bit_buffer = 0; if (m->no_ack) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_BASIC_GET_OK_METHOD: { amqp_basic_get_ok_t *m = (amqp_basic_get_ok_t *) decoded; E_64(encoded, offset, m->delivery_tag); offset += 8; bit_buffer = 0; if (m->redelivered) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; E_32(encoded, offset, m->message_count); offset += 4; return offset; } case AMQP_BASIC_GET_EMPTY_METHOD: { amqp_basic_get_empty_t *m = (amqp_basic_get_empty_t *) decoded; E_8(encoded, offset, m->cluster_id.len); offset++; E_BYTES(encoded, offset, m->cluster_id.len, m->cluster_id.bytes); offset += m->cluster_id.len; return offset; } case AMQP_BASIC_ACK_METHOD: { amqp_basic_ack_t *m = (amqp_basic_ack_t *) decoded; E_64(encoded, offset, m->delivery_tag); offset += 8; bit_buffer = 0; if (m->multiple) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_BASIC_REJECT_METHOD: { amqp_basic_reject_t *m = (amqp_basic_reject_t *) decoded; E_64(encoded, offset, m->delivery_tag); offset += 8; bit_buffer = 0; if (m->requeue) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_BASIC_RECOVER_METHOD: { amqp_basic_recover_t *m = (amqp_basic_recover_t *) decoded; bit_buffer = 0; if (m->requeue) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_FILE_QOS_METHOD: { amqp_file_qos_t *m = (amqp_file_qos_t *) decoded; E_32(encoded, offset, m->prefetch_size); offset += 4; E_16(encoded, offset, m->prefetch_count); offset += 2; bit_buffer = 0; if (m->global) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_FILE_QOS_OK_METHOD: { return offset; } case AMQP_FILE_CONSUME_METHOD: { amqp_file_consume_t *m = (amqp_file_consume_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; bit_buffer = 0; if (m->no_local) { bit_buffer |= (1 << 0); } if (m->no_ack) { bit_buffer |= (1 << 1); } if (m->exclusive) { bit_buffer |= (1 << 2); } if (m->nowait) { bit_buffer |= (1 << 3); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_FILE_CONSUME_OK_METHOD: { amqp_file_consume_ok_t *m = (amqp_file_consume_ok_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; return offset; } case AMQP_FILE_CANCEL_METHOD: { amqp_file_cancel_t *m = (amqp_file_cancel_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; bit_buffer = 0; if (m->nowait) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_FILE_CANCEL_OK_METHOD: { amqp_file_cancel_ok_t *m = (amqp_file_cancel_ok_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; return offset; } case AMQP_FILE_OPEN_METHOD: { amqp_file_open_t *m = (amqp_file_open_t *) decoded; E_8(encoded, offset, m->identifier.len); offset++; E_BYTES(encoded, offset, m->identifier.len, m->identifier.bytes); offset += m->identifier.len; E_64(encoded, offset, m->content_size); offset += 8; return offset; } case AMQP_FILE_OPEN_OK_METHOD: { amqp_file_open_ok_t *m = (amqp_file_open_ok_t *) decoded; E_64(encoded, offset, m->staged_size); offset += 8; return offset; } case AMQP_FILE_STAGE_METHOD: { return offset; } case AMQP_FILE_PUBLISH_METHOD: { amqp_file_publish_t *m = (amqp_file_publish_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; bit_buffer = 0; if (m->mandatory) { bit_buffer |= (1 << 0); } if (m->immediate) { bit_buffer |= (1 << 1); } E_8(encoded, offset, bit_buffer); offset++; E_8(encoded, offset, m->identifier.len); offset++; E_BYTES(encoded, offset, m->identifier.len, m->identifier.bytes); offset += m->identifier.len; return offset; } case AMQP_FILE_RETURN_METHOD: { amqp_file_return_t *m = (amqp_file_return_t *) decoded; E_16(encoded, offset, m->reply_code); offset += 2; E_8(encoded, offset, m->reply_text.len); offset++; E_BYTES(encoded, offset, m->reply_text.len, m->reply_text.bytes); offset += m->reply_text.len; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; return offset; } case AMQP_FILE_DELIVER_METHOD: { amqp_file_deliver_t *m = (amqp_file_deliver_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; E_64(encoded, offset, m->delivery_tag); offset += 8; bit_buffer = 0; if (m->redelivered) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; E_8(encoded, offset, m->identifier.len); offset++; E_BYTES(encoded, offset, m->identifier.len, m->identifier.bytes); offset += m->identifier.len; return offset; } case AMQP_FILE_ACK_METHOD: { amqp_file_ack_t *m = (amqp_file_ack_t *) decoded; E_64(encoded, offset, m->delivery_tag); offset += 8; bit_buffer = 0; if (m->multiple) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_FILE_REJECT_METHOD: { amqp_file_reject_t *m = (amqp_file_reject_t *) decoded; E_64(encoded, offset, m->delivery_tag); offset += 8; bit_buffer = 0; if (m->requeue) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_STREAM_QOS_METHOD: { amqp_stream_qos_t *m = (amqp_stream_qos_t *) decoded; E_32(encoded, offset, m->prefetch_size); offset += 4; E_16(encoded, offset, m->prefetch_count); offset += 2; E_32(encoded, offset, m->consume_rate); offset += 4; bit_buffer = 0; if (m->global) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_STREAM_QOS_OK_METHOD: { return offset; } case AMQP_STREAM_CONSUME_METHOD: { amqp_stream_consume_t *m = (amqp_stream_consume_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; bit_buffer = 0; if (m->no_local) { bit_buffer |= (1 << 0); } if (m->exclusive) { bit_buffer |= (1 << 1); } if (m->nowait) { bit_buffer |= (1 << 2); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_STREAM_CONSUME_OK_METHOD: { amqp_stream_consume_ok_t *m = (amqp_stream_consume_ok_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; return offset; } case AMQP_STREAM_CANCEL_METHOD: { amqp_stream_cancel_t *m = (amqp_stream_cancel_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; bit_buffer = 0; if (m->nowait) { bit_buffer |= (1 << 0); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_STREAM_CANCEL_OK_METHOD: { amqp_stream_cancel_ok_t *m = (amqp_stream_cancel_ok_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; return offset; } case AMQP_STREAM_PUBLISH_METHOD: { amqp_stream_publish_t *m = (amqp_stream_publish_t *) decoded; E_16(encoded, offset, m->ticket); offset += 2; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; bit_buffer = 0; if (m->mandatory) { bit_buffer |= (1 << 0); } if (m->immediate) { bit_buffer |= (1 << 1); } E_8(encoded, offset, bit_buffer); offset++; return offset; } case AMQP_STREAM_RETURN_METHOD: { amqp_stream_return_t *m = (amqp_stream_return_t *) decoded; E_16(encoded, offset, m->reply_code); offset += 2; E_8(encoded, offset, m->reply_text.len); offset++; E_BYTES(encoded, offset, m->reply_text.len, m->reply_text.bytes); offset += m->reply_text.len; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->routing_key.len); offset++; E_BYTES(encoded, offset, m->routing_key.len, m->routing_key.bytes); offset += m->routing_key.len; return offset; } case AMQP_STREAM_DELIVER_METHOD: { amqp_stream_deliver_t *m = (amqp_stream_deliver_t *) decoded; E_8(encoded, offset, m->consumer_tag.len); offset++; E_BYTES(encoded, offset, m->consumer_tag.len, m->consumer_tag.bytes); offset += m->consumer_tag.len; E_64(encoded, offset, m->delivery_tag); offset += 8; E_8(encoded, offset, m->exchange.len); offset++; E_BYTES(encoded, offset, m->exchange.len, m->exchange.bytes); offset += m->exchange.len; E_8(encoded, offset, m->queue.len); offset++; E_BYTES(encoded, offset, m->queue.len, m->queue.bytes); offset += m->queue.len; return offset; } case AMQP_TX_SELECT_METHOD: { return offset; } case AMQP_TX_SELECT_OK_METHOD: { return offset; } case AMQP_TX_COMMIT_METHOD: { return offset; } case AMQP_TX_COMMIT_OK_METHOD: { return offset; } case AMQP_TX_ROLLBACK_METHOD: { return offset; } case AMQP_TX_ROLLBACK_OK_METHOD: { return offset; } case AMQP_DTX_SELECT_METHOD: { return offset; } case AMQP_DTX_SELECT_OK_METHOD: { return offset; } case AMQP_DTX_START_METHOD: { amqp_dtx_start_t *m = (amqp_dtx_start_t *) decoded; E_8(encoded, offset, m->dtx_identifier.len); offset++; E_BYTES(encoded, offset, m->dtx_identifier.len, m->dtx_identifier.bytes); offset += m->dtx_identifier.len; return offset; } case AMQP_DTX_START_OK_METHOD: { return offset; } case AMQP_TUNNEL_REQUEST_METHOD: { amqp_tunnel_request_t *m = (amqp_tunnel_request_t *) decoded; table_result = amqp_encode_table(encoded, &(m->meta_data), &offset); if (table_result < 0) return table_result; return offset; } case AMQP_TEST_INTEGER_METHOD: { amqp_test_integer_t *m = (amqp_test_integer_t *) decoded; E_8(encoded, offset, m->integer_1); offset++; E_16(encoded, offset, m->integer_2); offset += 2; E_32(encoded, offset, m->integer_3); offset += 4; E_64(encoded, offset, m->integer_4); offset += 8; E_8(encoded, offset, m->operation); offset++; return offset; } case AMQP_TEST_INTEGER_OK_METHOD: { amqp_test_integer_ok_t *m = (amqp_test_integer_ok_t *) decoded; E_64(encoded, offset, m->result); offset += 8; return offset; } case AMQP_TEST_STRING_METHOD: { amqp_test_string_t *m = (amqp_test_string_t *) decoded; E_8(encoded, offset, m->string_1.len); offset++; E_BYTES(encoded, offset, m->string_1.len, m->string_1.bytes); offset += m->string_1.len; E_32(encoded, offset, m->string_2.len); offset += 4; E_BYTES(encoded, offset, m->string_2.len, m->string_2.bytes); offset += m->string_2.len; E_8(encoded, offset, m->operation); offset++; return offset; } case AMQP_TEST_STRING_OK_METHOD: { amqp_test_string_ok_t *m = (amqp_test_string_ok_t *) decoded; E_32(encoded, offset, m->result.len); offset += 4; E_BYTES(encoded, offset, m->result.len, m->result.bytes); offset += m->result.len; return offset; } case AMQP_TEST_TABLE_METHOD: { amqp_test_table_t *m = (amqp_test_table_t *) decoded; table_result = amqp_encode_table(encoded, &(m->table), &offset); if (table_result < 0) return table_result; E_8(encoded, offset, m->integer_op); offset++; E_8(encoded, offset, m->string_op); offset++; return offset; } case AMQP_TEST_TABLE_OK_METHOD: { amqp_test_table_ok_t *m = (amqp_test_table_ok_t *) decoded; E_64(encoded, offset, m->integer_result); offset += 8; E_32(encoded, offset, m->string_result.len); offset += 4; E_BYTES(encoded, offset, m->string_result.len, m->string_result.bytes); offset += m->string_result.len; return offset; } case AMQP_TEST_CONTENT_METHOD: { return offset; } case AMQP_TEST_CONTENT_OK_METHOD: { amqp_test_content_ok_t *m = (amqp_test_content_ok_t *) decoded; E_32(encoded, offset, m->content_checksum); offset += 4; return offset; } default: return -ENOENT; } } int amqp_encode_properties(uint16_t class_id, void *decoded, amqp_bytes_t encoded) { int offset = 0; int table_result; /* Cheat, and get the flags out generically, relying on the similarity of structure between classes */ amqp_flags_t flags = * (amqp_flags_t *) decoded; /* cheating! */ { /* We take a copy of flags to avoid destroying it, as it is used in the autogenerated code below. */ amqp_flags_t remaining_flags = flags; do { amqp_flags_t remainder = remaining_flags >> 16; uint16_t partial_flags = remaining_flags & 0xFFFE; if (remainder != 0) { partial_flags |= 1; } E_16(encoded, offset, partial_flags); offset += 2; remaining_flags = remainder; } while (remaining_flags != 0); } switch (class_id) { case 10: { return offset; } case 20: { return offset; } case 30: { return offset; } case 40: { return offset; } case 50: { return offset; } case 60: { amqp_basic_properties_t *p = (amqp_basic_properties_t *) decoded; if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { E_8(encoded, offset, p->content_type.len); offset++; E_BYTES(encoded, offset, p->content_type.len, p->content_type.bytes); offset += p->content_type.len; } if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) { E_8(encoded, offset, p->content_encoding.len); offset++; E_BYTES(encoded, offset, p->content_encoding.len, p->content_encoding.bytes); offset += p->content_encoding.len; } if (flags & AMQP_BASIC_HEADERS_FLAG) { table_result = amqp_encode_table(encoded, &(p->headers), &offset); if (table_result < 0) return table_result; } if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) { E_8(encoded, offset, p->delivery_mode); offset++; } if (flags & AMQP_BASIC_PRIORITY_FLAG) { E_8(encoded, offset, p->priority); offset++; } if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) { E_8(encoded, offset, p->correlation_id.len); offset++; E_BYTES(encoded, offset, p->correlation_id.len, p->correlation_id.bytes); offset += p->correlation_id.len; } if (flags & AMQP_BASIC_REPLY_TO_FLAG) { E_8(encoded, offset, p->reply_to.len); offset++; E_BYTES(encoded, offset, p->reply_to.len, p->reply_to.bytes); offset += p->reply_to.len; } if (flags & AMQP_BASIC_EXPIRATION_FLAG) { E_8(encoded, offset, p->expiration.len); offset++; E_BYTES(encoded, offset, p->expiration.len, p->expiration.bytes); offset += p->expiration.len; } if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) { E_8(encoded, offset, p->message_id.len); offset++; E_BYTES(encoded, offset, p->message_id.len, p->message_id.bytes); offset += p->message_id.len; } if (flags & AMQP_BASIC_TIMESTAMP_FLAG) { E_64(encoded, offset, p->timestamp); offset += 8; } if (flags & AMQP_BASIC_TYPE_FLAG) { E_8(encoded, offset, p->type.len); offset++; E_BYTES(encoded, offset, p->type.len, p->type.bytes); offset += p->type.len; } if (flags & AMQP_BASIC_USER_ID_FLAG) { E_8(encoded, offset, p->user_id.len); offset++; E_BYTES(encoded, offset, p->user_id.len, p->user_id.bytes); offset += p->user_id.len; } if (flags & AMQP_BASIC_APP_ID_FLAG) { E_8(encoded, offset, p->app_id.len); offset++; E_BYTES(encoded, offset, p->app_id.len, p->app_id.bytes); offset += p->app_id.len; } if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) { E_8(encoded, offset, p->cluster_id.len); offset++; E_BYTES(encoded, offset, p->cluster_id.len, p->cluster_id.bytes); offset += p->cluster_id.len; } return offset; } case 70: { amqp_file_properties_t *p = (amqp_file_properties_t *) decoded; if (flags & AMQP_FILE_CONTENT_TYPE_FLAG) { E_8(encoded, offset, p->content_type.len); offset++; E_BYTES(encoded, offset, p->content_type.len, p->content_type.bytes); offset += p->content_type.len; } if (flags & AMQP_FILE_CONTENT_ENCODING_FLAG) { E_8(encoded, offset, p->content_encoding.len); offset++; E_BYTES(encoded, offset, p->content_encoding.len, p->content_encoding.bytes); offset += p->content_encoding.len; } if (flags & AMQP_FILE_HEADERS_FLAG) { table_result = amqp_encode_table(encoded, &(p->headers), &offset); if (table_result < 0) return table_result; } if (flags & AMQP_FILE_PRIORITY_FLAG) { E_8(encoded, offset, p->priority); offset++; } if (flags & AMQP_FILE_REPLY_TO_FLAG) { E_8(encoded, offset, p->reply_to.len); offset++; E_BYTES(encoded, offset, p->reply_to.len, p->reply_to.bytes); offset += p->reply_to.len; } if (flags & AMQP_FILE_MESSAGE_ID_FLAG) { E_8(encoded, offset, p->message_id.len); offset++; E_BYTES(encoded, offset, p->message_id.len, p->message_id.bytes); offset += p->message_id.len; } if (flags & AMQP_FILE_FILENAME_FLAG) { E_8(encoded, offset, p->filename.len); offset++; E_BYTES(encoded, offset, p->filename.len, p->filename.bytes); offset += p->filename.len; } if (flags & AMQP_FILE_TIMESTAMP_FLAG) { E_64(encoded, offset, p->timestamp); offset += 8; } if (flags & AMQP_FILE_CLUSTER_ID_FLAG) { E_8(encoded, offset, p->cluster_id.len); offset++; E_BYTES(encoded, offset, p->cluster_id.len, p->cluster_id.bytes); offset += p->cluster_id.len; } return offset; } case 80: { amqp_stream_properties_t *p = (amqp_stream_properties_t *) decoded; if (flags & AMQP_STREAM_CONTENT_TYPE_FLAG) { E_8(encoded, offset, p->content_type.len); offset++; E_BYTES(encoded, offset, p->content_type.len, p->content_type.bytes); offset += p->content_type.len; } if (flags & AMQP_STREAM_CONTENT_ENCODING_FLAG) { E_8(encoded, offset, p->content_encoding.len); offset++; E_BYTES(encoded, offset, p->content_encoding.len, p->content_encoding.bytes); offset += p->content_encoding.len; } if (flags & AMQP_STREAM_HEADERS_FLAG) { table_result = amqp_encode_table(encoded, &(p->headers), &offset); if (table_result < 0) return table_result; } if (flags & AMQP_STREAM_PRIORITY_FLAG) { E_8(encoded, offset, p->priority); offset++; } if (flags & AMQP_STREAM_TIMESTAMP_FLAG) { E_64(encoded, offset, p->timestamp); offset += 8; } return offset; } case 90: { return offset; } case 100: { return offset; } case 110: { amqp_tunnel_properties_t *p = (amqp_tunnel_properties_t *) decoded; if (flags & AMQP_TUNNEL_HEADERS_FLAG) { table_result = amqp_encode_table(encoded, &(p->headers), &offset); if (table_result < 0) return table_result; } if (flags & AMQP_TUNNEL_PROXY_NAME_FLAG) { E_8(encoded, offset, p->proxy_name.len); offset++; E_BYTES(encoded, offset, p->proxy_name.len, p->proxy_name.bytes); offset += p->proxy_name.len; } if (flags & AMQP_TUNNEL_DATA_NAME_FLAG) { E_8(encoded, offset, p->data_name.len); offset++; E_BYTES(encoded, offset, p->data_name.len, p->data_name.bytes); offset += p->data_name.len; } if (flags & AMQP_TUNNEL_DURABLE_FLAG) { E_8(encoded, offset, p->durable); offset++; } if (flags & AMQP_TUNNEL_BROADCAST_FLAG) { E_8(encoded, offset, p->broadcast); offset++; } return offset; } case 120: { return offset; } default: return -ENOENT; } }