summaryrefslogtreecommitdiff
path: root/include
diff options
context:
space:
mode:
authorAlan Antonuk <alan.antonuk@gmail.com>2021-04-21 05:11:11 +0000
committerAlan Antonuk <alan.antonuk@gmail.com>2021-04-20 22:45:35 -0700
commit2d251e2d2b19f14a7f02fe1f922f148c751df402 (patch)
tree60173740a044ae0374e2b95028389dce9e7d4865 /include
parent4c459490180b6843d36508da82efbf58f683ca7d (diff)
downloadrabbitmq-c-2d251e2d2b19f14a7f02fe1f922f148c751df402.tar.gz
lib: regenerate framing with codegen v3.8.14
Signed-off-by: GitHub <noreply@github.com>
Diffstat (limited to 'include')
-rw-r--r--include/rabbitmq-c/framing.h324
1 files changed, 180 insertions, 144 deletions
diff --git a/include/rabbitmq-c/framing.h b/include/rabbitmq-c/framing.h
index 3da0bef..99c51c0 100644
--- a/include/rabbitmq-c/framing.h
+++ b/include/rabbitmq-c/framing.h
@@ -34,7 +34,7 @@
* ***** END LICENSE BLOCK *****
*/
-/** @file amqp_framing.h */
+/** @file rabbitmq-c/framing.h */
#ifndef RABBITMQ_C_FRAMING_H
#define RABBITMQ_C_FRAMING_H
@@ -43,37 +43,36 @@
AMQP_BEGIN_DECLS
-#define AMQP_PROTOCOL_VERSION_MAJOR 0 /**< AMQP protocol version major */
-#define AMQP_PROTOCOL_VERSION_MINOR 9 /**< AMQP protocol version minor */
-#define AMQP_PROTOCOL_VERSION_REVISION \
- 1 /**< AMQP protocol version revision \
- */
-#define AMQP_PROTOCOL_PORT 5672 /**< Default AMQP Port */
-#define AMQP_FRAME_METHOD 1 /**< Constant: FRAME-METHOD */
-#define AMQP_FRAME_HEADER 2 /**< Constant: FRAME-HEADER */
-#define AMQP_FRAME_BODY 3 /**< Constant: FRAME-BODY */
-#define AMQP_FRAME_HEARTBEAT 8 /**< Constant: FRAME-HEARTBEAT */
-#define AMQP_FRAME_MIN_SIZE 4096 /**< Constant: FRAME-MIN-SIZE */
-#define AMQP_FRAME_END 206 /**< Constant: FRAME-END */
-#define AMQP_REPLY_SUCCESS 200 /**< Constant: REPLY-SUCCESS */
-#define AMQP_CONTENT_TOO_LARGE 311 /**< Constant: CONTENT-TOO-LARGE */
-#define AMQP_NO_ROUTE 312 /**< Constant: NO-ROUTE */
-#define AMQP_NO_CONSUMERS 313 /**< Constant: NO-CONSUMERS */
-#define AMQP_ACCESS_REFUSED 403 /**< Constant: ACCESS-REFUSED */
-#define AMQP_NOT_FOUND 404 /**< Constant: NOT-FOUND */
-#define AMQP_RESOURCE_LOCKED 405 /**< Constant: RESOURCE-LOCKED */
-#define AMQP_PRECONDITION_FAILED 406 /**< Constant: PRECONDITION-FAILED */
-#define AMQP_CONNECTION_FORCED 320 /**< Constant: CONNECTION-FORCED */
-#define AMQP_INVALID_PATH 402 /**< Constant: INVALID-PATH */
-#define AMQP_FRAME_ERROR 501 /**< Constant: FRAME-ERROR */
-#define AMQP_SYNTAX_ERROR 502 /**< Constant: SYNTAX-ERROR */
-#define AMQP_COMMAND_INVALID 503 /**< Constant: COMMAND-INVALID */
-#define AMQP_CHANNEL_ERROR 504 /**< Constant: CHANNEL-ERROR */
-#define AMQP_UNEXPECTED_FRAME 505 /**< Constant: UNEXPECTED-FRAME */
-#define AMQP_RESOURCE_ERROR 506 /**< Constant: RESOURCE-ERROR */
-#define AMQP_NOT_ALLOWED 530 /**< Constant: NOT-ALLOWED */
-#define AMQP_NOT_IMPLEMENTED 540 /**< Constant: NOT-IMPLEMENTED */
-#define AMQP_INTERNAL_ERROR 541 /**< Constant: INTERNAL-ERROR */
+#define AMQP_PROTOCOL_VERSION_MAJOR 0 /**< AMQP protocol version major */
+#define AMQP_PROTOCOL_VERSION_MINOR 9 /**< AMQP protocol version minor */
+#define AMQP_PROTOCOL_VERSION_REVISION 1 /**< AMQP protocol version revision \
+ */
+#define AMQP_PROTOCOL_PORT 5672 /**< Default AMQP Port */
+#define AMQP_FRAME_METHOD 1 /**< Constant: FRAME-METHOD */
+#define AMQP_FRAME_HEADER 2 /**< Constant: FRAME-HEADER */
+#define AMQP_FRAME_BODY 3 /**< Constant: FRAME-BODY */
+#define AMQP_FRAME_HEARTBEAT 8 /**< Constant: FRAME-HEARTBEAT */
+#define AMQP_FRAME_MIN_SIZE 4096 /**< Constant: FRAME-MIN-SIZE */
+#define AMQP_FRAME_END 206 /**< Constant: FRAME-END */
+#define AMQP_REPLY_SUCCESS 200 /**< Constant: REPLY-SUCCESS */
+#define AMQP_CONTENT_TOO_LARGE 311 /**< Constant: CONTENT-TOO-LARGE */
+#define AMQP_NO_ROUTE 312 /**< Constant: NO-ROUTE */
+#define AMQP_NO_CONSUMERS 313 /**< Constant: NO-CONSUMERS */
+#define AMQP_ACCESS_REFUSED 403 /**< Constant: ACCESS-REFUSED */
+#define AMQP_NOT_FOUND 404 /**< Constant: NOT-FOUND */
+#define AMQP_RESOURCE_LOCKED 405 /**< Constant: RESOURCE-LOCKED */
+#define AMQP_PRECONDITION_FAILED 406 /**< Constant: PRECONDITION-FAILED */
+#define AMQP_CONNECTION_FORCED 320 /**< Constant: CONNECTION-FORCED */
+#define AMQP_INVALID_PATH 402 /**< Constant: INVALID-PATH */
+#define AMQP_FRAME_ERROR 501 /**< Constant: FRAME-ERROR */
+#define AMQP_SYNTAX_ERROR 502 /**< Constant: SYNTAX-ERROR */
+#define AMQP_COMMAND_INVALID 503 /**< Constant: COMMAND-INVALID */
+#define AMQP_CHANNEL_ERROR 504 /**< Constant: CHANNEL-ERROR */
+#define AMQP_UNEXPECTED_FRAME 505 /**< Constant: UNEXPECTED-FRAME */
+#define AMQP_RESOURCE_ERROR 506 /**< Constant: RESOURCE-ERROR */
+#define AMQP_NOT_ALLOWED 530 /**< Constant: NOT-ALLOWED */
+#define AMQP_NOT_IMPLEMENTED 540 /**< Constant: NOT-IMPLEMENTED */
+#define AMQP_INTERNAL_ERROR 541 /**< Constant: INTERNAL-ERROR */
/* Function prototypes. */
@@ -169,8 +168,7 @@ int AMQP_CALL amqp_encode_method(amqp_method_number_t methodNumber,
* @param [in] class_id the class id for the decoded parameter
* @param [in] decoded the properties structure (e.g., amqp_basic_properties_t)
* @param [in] encoded an allocated byte buffer for the encoded properties to
- * written to.
- * If the buffer isn't large enough to hold the encoded method, an
+ * written to. If the buffer isn't large enough to hold the encoded method, an
* an error code will be returned
* @returns 0 on success, an error code otherwise.
*/
@@ -180,9 +178,9 @@ int AMQP_CALL amqp_encode_properties(uint16_t class_id, void *decoded,
/* Method field records. */
-#define AMQP_CONNECTION_START_METHOD \
- ((amqp_method_number_t)0x000A000A) /**< connection.start method id \
- @internal 10, 10; 655370 */
+#define AMQP_CONNECTION_START_METHOD \
+ ((amqp_method_number_t)0x000A000A) /**< connection.start method id @internal \
+ 10, 10; 655370 */
/** connection.start method fields */
typedef struct amqp_connection_start_t_ {
uint8_t version_major; /**< version-major */
@@ -219,9 +217,9 @@ typedef struct amqp_connection_secure_ok_t_ {
amqp_bytes_t response; /**< response */
} amqp_connection_secure_ok_t;
-#define AMQP_CONNECTION_TUNE_METHOD \
- ((amqp_method_number_t)0x000A001E) /**< connection.tune method id \
- @internal 10, 30; 655390 */
+#define AMQP_CONNECTION_TUNE_METHOD \
+ ((amqp_method_number_t)0x000A001E) /**< connection.tune method id @internal \
+ 10, 30; 655390 */
/** connection.tune method fields */
typedef struct amqp_connection_tune_t_ {
uint16_t channel_max; /**< channel-max */
@@ -239,9 +237,9 @@ typedef struct amqp_connection_tune_ok_t_ {
uint16_t heartbeat; /**< heartbeat */
} amqp_connection_tune_ok_t;
-#define AMQP_CONNECTION_OPEN_METHOD \
- ((amqp_method_number_t)0x000A0028) /**< connection.open method id \
- @internal 10, 40; 655400 */
+#define AMQP_CONNECTION_OPEN_METHOD \
+ ((amqp_method_number_t)0x000A0028) /**< connection.open method id @internal \
+ 10, 40; 655400 */
/** connection.open method fields */
typedef struct amqp_connection_open_t_ {
amqp_bytes_t virtual_host; /**< virtual-host */
@@ -257,9 +255,9 @@ typedef struct amqp_connection_open_ok_t_ {
amqp_bytes_t known_hosts; /**< known-hosts */
} amqp_connection_open_ok_t;
-#define AMQP_CONNECTION_CLOSE_METHOD \
- ((amqp_method_number_t)0x000A0032) /**< connection.close method id \
- @internal 10, 50; 655410 */
+#define AMQP_CONNECTION_CLOSE_METHOD \
+ ((amqp_method_number_t)0x000A0032) /**< connection.close method id @internal \
+ 10, 50; 655410 */
/** connection.close method fields */
typedef struct amqp_connection_close_t_ {
uint16_t reply_code; /**< reply-code */
@@ -292,33 +290,50 @@ typedef struct amqp_connection_unblocked_t_ {
char dummy; /**< Dummy field to avoid empty struct */
} amqp_connection_unblocked_t;
-#define AMQP_CHANNEL_OPEN_METHOD \
- ((amqp_method_number_t)0x0014000A) /**< channel.open method id @internal \
- 20, 10; 1310730 */
+#define AMQP_CONNECTION_UPDATE_SECRET_METHOD \
+ ((amqp_method_number_t)0x000A0046) /**< connection.update-secret method id \
+ @internal 10, 70; 655430 */
+/** connection.update-secret method fields */
+typedef struct amqp_connection_update_secret_t_ {
+ amqp_bytes_t new_secret; /**< new-secret */
+ amqp_bytes_t reason; /**< reason */
+} amqp_connection_update_secret_t;
+
+#define AMQP_CONNECTION_UPDATE_SECRET_OK_METHOD \
+ ((amqp_method_number_t)0x000A0047) /**< connection.update-secret-ok method \
+ id @internal 10, 71; 655431 */
+/** connection.update-secret-ok method fields */
+typedef struct amqp_connection_update_secret_ok_t_ {
+ char dummy; /**< Dummy field to avoid empty struct */
+} amqp_connection_update_secret_ok_t;
+
+#define AMQP_CHANNEL_OPEN_METHOD \
+ ((amqp_method_number_t)0x0014000A) /**< channel.open method id @internal 20, \
+ 10; 1310730 */
/** channel.open method fields */
typedef struct amqp_channel_open_t_ {
amqp_bytes_t out_of_band; /**< out-of-band */
} amqp_channel_open_t;
-#define AMQP_CHANNEL_OPEN_OK_METHOD \
- ((amqp_method_number_t)0x0014000B) /**< channel.open-ok method id \
- @internal 20, 11; 1310731 */
+#define AMQP_CHANNEL_OPEN_OK_METHOD \
+ ((amqp_method_number_t)0x0014000B) /**< channel.open-ok method id @internal \
+ 20, 11; 1310731 */
/** channel.open-ok method fields */
typedef struct amqp_channel_open_ok_t_ {
amqp_bytes_t channel_id; /**< channel-id */
} amqp_channel_open_ok_t;
-#define AMQP_CHANNEL_FLOW_METHOD \
- ((amqp_method_number_t)0x00140014) /**< channel.flow method id @internal \
- 20, 20; 1310740 */
+#define AMQP_CHANNEL_FLOW_METHOD \
+ ((amqp_method_number_t)0x00140014) /**< channel.flow method id @internal 20, \
+ 20; 1310740 */
/** channel.flow method fields */
typedef struct amqp_channel_flow_t_ {
amqp_boolean_t active; /**< active */
} amqp_channel_flow_t;
-#define AMQP_CHANNEL_FLOW_OK_METHOD \
- ((amqp_method_number_t)0x00140015) /**< channel.flow-ok method id \
- @internal 20, 21; 1310741 */
+#define AMQP_CHANNEL_FLOW_OK_METHOD \
+ ((amqp_method_number_t)0x00140015) /**< channel.flow-ok method id @internal \
+ 20, 21; 1310741 */
/** channel.flow-ok method fields */
typedef struct amqp_channel_flow_ok_t_ {
amqp_boolean_t active; /**< active */
@@ -335,9 +350,9 @@ typedef struct amqp_channel_close_t_ {
uint16_t method_id; /**< method-id */
} amqp_channel_close_t;
-#define AMQP_CHANNEL_CLOSE_OK_METHOD \
- ((amqp_method_number_t)0x00140029) /**< channel.close-ok method id \
- @internal 20, 41; 1310761 */
+#define AMQP_CHANNEL_CLOSE_OK_METHOD \
+ ((amqp_method_number_t)0x00140029) /**< channel.close-ok method id @internal \
+ 20, 41; 1310761 */
/** channel.close-ok method fields */
typedef struct amqp_channel_close_ok_t_ {
char dummy; /**< Dummy field to avoid empty struct */
@@ -364,9 +379,9 @@ typedef struct amqp_access_request_ok_t_ {
uint16_t ticket; /**< ticket */
} amqp_access_request_ok_t;
-#define AMQP_EXCHANGE_DECLARE_METHOD \
- ((amqp_method_number_t)0x0028000A) /**< exchange.declare method id \
- @internal 40, 10; 2621450 */
+#define AMQP_EXCHANGE_DECLARE_METHOD \
+ ((amqp_method_number_t)0x0028000A) /**< exchange.declare method id @internal \
+ 40, 10; 2621450 */
/** exchange.declare method fields */
typedef struct amqp_exchange_declare_t_ {
uint16_t ticket; /**< ticket */
@@ -388,9 +403,9 @@ typedef struct amqp_exchange_declare_ok_t_ {
char dummy; /**< Dummy field to avoid empty struct */
} amqp_exchange_declare_ok_t;
-#define AMQP_EXCHANGE_DELETE_METHOD \
- ((amqp_method_number_t)0x00280014) /**< exchange.delete method id \
- @internal 40, 20; 2621460 */
+#define AMQP_EXCHANGE_DELETE_METHOD \
+ ((amqp_method_number_t)0x00280014) /**< exchange.delete method id @internal \
+ 40, 20; 2621460 */
/** exchange.delete method fields */
typedef struct amqp_exchange_delete_t_ {
uint16_t ticket; /**< ticket */
@@ -420,17 +435,17 @@ typedef struct amqp_exchange_bind_t_ {
amqp_table_t arguments; /**< arguments */
} amqp_exchange_bind_t;
-#define AMQP_EXCHANGE_BIND_OK_METHOD \
- ((amqp_method_number_t)0x0028001F) /**< exchange.bind-ok method id \
- @internal 40, 31; 2621471 */
+#define AMQP_EXCHANGE_BIND_OK_METHOD \
+ ((amqp_method_number_t)0x0028001F) /**< exchange.bind-ok method id @internal \
+ 40, 31; 2621471 */
/** exchange.bind-ok method fields */
typedef struct amqp_exchange_bind_ok_t_ {
char dummy; /**< Dummy field to avoid empty struct */
} amqp_exchange_bind_ok_t;
-#define AMQP_EXCHANGE_UNBIND_METHOD \
- ((amqp_method_number_t)0x00280028) /**< exchange.unbind method id \
- @internal 40, 40; 2621480 */
+#define AMQP_EXCHANGE_UNBIND_METHOD \
+ ((amqp_method_number_t)0x00280028) /**< exchange.unbind method id @internal \
+ 40, 40; 2621480 */
/** exchange.unbind method fields */
typedef struct amqp_exchange_unbind_t_ {
uint16_t ticket; /**< ticket */
@@ -464,9 +479,9 @@ typedef struct amqp_queue_declare_t_ {
amqp_table_t arguments; /**< arguments */
} amqp_queue_declare_t;
-#define AMQP_QUEUE_DECLARE_OK_METHOD \
- ((amqp_method_number_t)0x0032000B) /**< queue.declare-ok method id \
- @internal 50, 11; 3276811 */
+#define AMQP_QUEUE_DECLARE_OK_METHOD \
+ ((amqp_method_number_t)0x0032000B) /**< queue.declare-ok method id @internal \
+ 50, 11; 3276811 */
/** queue.declare-ok method fields */
typedef struct amqp_queue_declare_ok_t_ {
amqp_bytes_t queue; /**< queue */
@@ -495,9 +510,9 @@ typedef struct amqp_queue_bind_ok_t_ {
char dummy; /**< Dummy field to avoid empty struct */
} amqp_queue_bind_ok_t;
-#define AMQP_QUEUE_PURGE_METHOD \
- ((amqp_method_number_t)0x0032001E) /**< queue.purge method id @internal \
- 50, 30; 3276830 */
+#define AMQP_QUEUE_PURGE_METHOD \
+ ((amqp_method_number_t)0x0032001E) /**< queue.purge method id @internal 50, \
+ 30; 3276830 */
/** queue.purge method fields */
typedef struct amqp_queue_purge_t_ {
uint16_t ticket; /**< ticket */
@@ -513,9 +528,9 @@ typedef struct amqp_queue_purge_ok_t_ {
uint32_t message_count; /**< message-count */
} amqp_queue_purge_ok_t;
-#define AMQP_QUEUE_DELETE_METHOD \
- ((amqp_method_number_t)0x00320028) /**< queue.delete method id @internal \
- 50, 40; 3276840 */
+#define AMQP_QUEUE_DELETE_METHOD \
+ ((amqp_method_number_t)0x00320028) /**< queue.delete method id @internal 50, \
+ 40; 3276840 */
/** queue.delete method fields */
typedef struct amqp_queue_delete_t_ {
uint16_t ticket; /**< ticket */
@@ -525,17 +540,17 @@ typedef struct amqp_queue_delete_t_ {
amqp_boolean_t nowait; /**< nowait */
} amqp_queue_delete_t;
-#define AMQP_QUEUE_DELETE_OK_METHOD \
- ((amqp_method_number_t)0x00320029) /**< queue.delete-ok method id \
- @internal 50, 41; 3276841 */
+#define AMQP_QUEUE_DELETE_OK_METHOD \
+ ((amqp_method_number_t)0x00320029) /**< queue.delete-ok method id @internal \
+ 50, 41; 3276841 */
/** queue.delete-ok method fields */
typedef struct amqp_queue_delete_ok_t_ {
uint32_t message_count; /**< message-count */
} amqp_queue_delete_ok_t;
-#define AMQP_QUEUE_UNBIND_METHOD \
- ((amqp_method_number_t)0x00320032) /**< queue.unbind method id @internal \
- 50, 50; 3276850 */
+#define AMQP_QUEUE_UNBIND_METHOD \
+ ((amqp_method_number_t)0x00320032) /**< queue.unbind method id @internal 50, \
+ 50; 3276850 */
/** queue.unbind method fields */
typedef struct amqp_queue_unbind_t_ {
uint16_t ticket; /**< ticket */
@@ -545,9 +560,9 @@ typedef struct amqp_queue_unbind_t_ {
amqp_table_t arguments; /**< arguments */
} amqp_queue_unbind_t;
-#define AMQP_QUEUE_UNBIND_OK_METHOD \
- ((amqp_method_number_t)0x00320033) /**< queue.unbind-ok method id \
- @internal 50, 51; 3276851 */
+#define AMQP_QUEUE_UNBIND_OK_METHOD \
+ ((amqp_method_number_t)0x00320033) /**< queue.unbind-ok method id @internal \
+ 50, 51; 3276851 */
/** queue.unbind-ok method fields */
typedef struct amqp_queue_unbind_ok_t_ {
char dummy; /**< Dummy field to avoid empty struct */
@@ -563,9 +578,9 @@ typedef struct amqp_basic_qos_t_ {
amqp_boolean_t global; /**< global */
} amqp_basic_qos_t;
-#define AMQP_BASIC_QOS_OK_METHOD \
- ((amqp_method_number_t)0x003C000B) /**< basic.qos-ok method id @internal \
- 60, 11; 3932171 */
+#define AMQP_BASIC_QOS_OK_METHOD \
+ ((amqp_method_number_t)0x003C000B) /**< basic.qos-ok method id @internal 60, \
+ 11; 3932171 */
/** basic.qos-ok method fields */
typedef struct amqp_basic_qos_ok_t_ {
char dummy; /**< Dummy field to avoid empty struct */
@@ -586,26 +601,26 @@ typedef struct amqp_basic_consume_t_ {
amqp_table_t arguments; /**< arguments */
} amqp_basic_consume_t;
-#define AMQP_BASIC_CONSUME_OK_METHOD \
- ((amqp_method_number_t)0x003C0015) /**< basic.consume-ok method id \
- @internal 60, 21; 3932181 */
+#define AMQP_BASIC_CONSUME_OK_METHOD \
+ ((amqp_method_number_t)0x003C0015) /**< basic.consume-ok method id @internal \
+ 60, 21; 3932181 */
/** basic.consume-ok method fields */
typedef struct amqp_basic_consume_ok_t_ {
amqp_bytes_t consumer_tag; /**< consumer-tag */
} amqp_basic_consume_ok_t;
-#define AMQP_BASIC_CANCEL_METHOD \
- ((amqp_method_number_t)0x003C001E) /**< basic.cancel method id @internal \
- 60, 30; 3932190 */
+#define AMQP_BASIC_CANCEL_METHOD \
+ ((amqp_method_number_t)0x003C001E) /**< basic.cancel method id @internal 60, \
+ 30; 3932190 */
/** basic.cancel method fields */
typedef struct amqp_basic_cancel_t_ {
amqp_bytes_t consumer_tag; /**< consumer-tag */
amqp_boolean_t nowait; /**< nowait */
} amqp_basic_cancel_t;
-#define AMQP_BASIC_CANCEL_OK_METHOD \
- ((amqp_method_number_t)0x003C001F) /**< basic.cancel-ok method id \
- @internal 60, 31; 3932191 */
+#define AMQP_BASIC_CANCEL_OK_METHOD \
+ ((amqp_method_number_t)0x003C001F) /**< basic.cancel-ok method id @internal \
+ 60, 31; 3932191 */
/** basic.cancel-ok method fields */
typedef struct amqp_basic_cancel_ok_t_ {
amqp_bytes_t consumer_tag; /**< consumer-tag */
@@ -623,9 +638,9 @@ typedef struct amqp_basic_publish_t_ {
amqp_boolean_t immediate; /**< immediate */
} amqp_basic_publish_t;
-#define AMQP_BASIC_RETURN_METHOD \
- ((amqp_method_number_t)0x003C0032) /**< basic.return method id @internal \
- 60, 50; 3932210 */
+#define AMQP_BASIC_RETURN_METHOD \
+ ((amqp_method_number_t)0x003C0032) /**< basic.return method id @internal 60, \
+ 50; 3932210 */
/** basic.return method fields */
typedef struct amqp_basic_return_t_ {
uint16_t reply_code; /**< reply-code */
@@ -656,9 +671,9 @@ typedef struct amqp_basic_get_t_ {
amqp_boolean_t no_ack; /**< no-ack */
} amqp_basic_get_t;
-#define AMQP_BASIC_GET_OK_METHOD \
- ((amqp_method_number_t)0x003C0047) /**< basic.get-ok method id @internal \
- 60, 71; 3932231 */
+#define AMQP_BASIC_GET_OK_METHOD \
+ ((amqp_method_number_t)0x003C0047) /**< basic.get-ok method id @internal 60, \
+ 71; 3932231 */
/** basic.get-ok method fields */
typedef struct amqp_basic_get_ok_t_ {
uint64_t delivery_tag; /**< delivery-tag */
@@ -668,9 +683,9 @@ typedef struct amqp_basic_get_ok_t_ {
uint32_t message_count; /**< message-count */
} amqp_basic_get_ok_t;
-#define AMQP_BASIC_GET_EMPTY_METHOD \
- ((amqp_method_number_t)0x003C0048) /**< basic.get-empty method id \
- @internal 60, 72; 3932232 */
+#define AMQP_BASIC_GET_EMPTY_METHOD \
+ ((amqp_method_number_t)0x003C0048) /**< basic.get-empty method id @internal \
+ 60, 72; 3932232 */
/** basic.get-empty method fields */
typedef struct amqp_basic_get_empty_t_ {
amqp_bytes_t cluster_id; /**< cluster-id */
@@ -685,9 +700,9 @@ typedef struct amqp_basic_ack_t_ {
amqp_boolean_t multiple; /**< multiple */
} amqp_basic_ack_t;
-#define AMQP_BASIC_REJECT_METHOD \
- ((amqp_method_number_t)0x003C005A) /**< basic.reject method id @internal \
- 60, 90; 3932250 */
+#define AMQP_BASIC_REJECT_METHOD \
+ ((amqp_method_number_t)0x003C005A) /**< basic.reject method id @internal 60, \
+ 90; 3932250 */
/** basic.reject method fields */
typedef struct amqp_basic_reject_t_ {
uint64_t delivery_tag; /**< delivery-tag */
@@ -710,9 +725,9 @@ typedef struct amqp_basic_recover_t_ {
amqp_boolean_t requeue; /**< requeue */
} amqp_basic_recover_t;
-#define AMQP_BASIC_RECOVER_OK_METHOD \
- ((amqp_method_number_t)0x003C006F) /**< basic.recover-ok method id \
- @internal 60, 111; 3932271 */
+#define AMQP_BASIC_RECOVER_OK_METHOD \
+ ((amqp_method_number_t)0x003C006F) /**< basic.recover-ok method id @internal \
+ 60, 111; 3932271 */
/** basic.recover-ok method fields */
typedef struct amqp_basic_recover_ok_t_ {
char dummy; /**< Dummy field to avoid empty struct */
@@ -736,9 +751,9 @@ typedef struct amqp_tx_select_t_ {
char dummy; /**< Dummy field to avoid empty struct */
} amqp_tx_select_t;
-#define AMQP_TX_SELECT_OK_METHOD \
- ((amqp_method_number_t)0x005A000B) /**< tx.select-ok method id @internal \
- 90, 11; 5898251 */
+#define AMQP_TX_SELECT_OK_METHOD \
+ ((amqp_method_number_t)0x005A000B) /**< tx.select-ok method id @internal 90, \
+ 11; 5898251 */
/** tx.select-ok method fields */
typedef struct amqp_tx_select_ok_t_ {
char dummy; /**< Dummy field to avoid empty struct */
@@ -752,17 +767,17 @@ typedef struct amqp_tx_commit_t_ {
char dummy; /**< Dummy field to avoid empty struct */
} amqp_tx_commit_t;
-#define AMQP_TX_COMMIT_OK_METHOD \
- ((amqp_method_number_t)0x005A0015) /**< tx.commit-ok method id @internal \
- 90, 21; 5898261 */
+#define AMQP_TX_COMMIT_OK_METHOD \
+ ((amqp_method_number_t)0x005A0015) /**< tx.commit-ok method id @internal 90, \
+ 21; 5898261 */
/** tx.commit-ok method fields */
typedef struct amqp_tx_commit_ok_t_ {
char dummy; /**< Dummy field to avoid empty struct */
} amqp_tx_commit_ok_t;
-#define AMQP_TX_ROLLBACK_METHOD \
- ((amqp_method_number_t)0x005A001E) /**< tx.rollback method id @internal \
- 90, 30; 5898270 */
+#define AMQP_TX_ROLLBACK_METHOD \
+ ((amqp_method_number_t)0x005A001E) /**< tx.rollback method id @internal 90, \
+ 30; 5898270 */
/** tx.rollback method fields */
typedef struct amqp_tx_rollback_t_ {
char dummy; /**< Dummy field to avoid empty struct */
@@ -793,9 +808,8 @@ typedef struct amqp_confirm_select_ok_t_ {
} amqp_confirm_select_ok_t;
/* Class property records. */
-#define AMQP_CONNECTION_CLASS \
- (0x000A) /**< connection class id @internal 10 \
- */
+#define AMQP_CONNECTION_CLASS (0x000A) /**< connection class id @internal 10 \
+ */
/** connection class properties */
typedef struct amqp_connection_properties_t_ {
amqp_flags_t _flags; /**< bit-mask of set fields */
@@ -831,20 +845,29 @@ typedef struct amqp_queue_properties_t_ {
} amqp_queue_properties_t;
#define AMQP_BASIC_CLASS (0x003C) /**< basic class id @internal 60 */
-#define AMQP_BASIC_CONTENT_TYPE_FLAG (1 << 15)
-#define AMQP_BASIC_CONTENT_ENCODING_FLAG (1 << 14)
-#define AMQP_BASIC_HEADERS_FLAG (1 << 13)
-#define AMQP_BASIC_DELIVERY_MODE_FLAG (1 << 12)
-#define AMQP_BASIC_PRIORITY_FLAG (1 << 11)
-#define AMQP_BASIC_CORRELATION_ID_FLAG (1 << 10)
-#define AMQP_BASIC_REPLY_TO_FLAG (1 << 9)
-#define AMQP_BASIC_EXPIRATION_FLAG (1 << 8)
-#define AMQP_BASIC_MESSAGE_ID_FLAG (1 << 7)
-#define AMQP_BASIC_TIMESTAMP_FLAG (1 << 6)
-#define AMQP_BASIC_TYPE_FLAG (1 << 5)
-#define AMQP_BASIC_USER_ID_FLAG (1 << 4)
-#define AMQP_BASIC_APP_ID_FLAG (1 << 3)
-#define AMQP_BASIC_CLUSTER_ID_FLAG (1 << 2)
+#define AMQP_BASIC_CONTENT_TYPE_FLAG \
+ (1 << 15) /**< basic.content-type property flag */
+#define AMQP_BASIC_CONTENT_ENCODING_FLAG \
+ (1 << 14) /**< basic.content-encoding property flag */
+#define AMQP_BASIC_HEADERS_FLAG (1 << 13) /**< basic.headers property flag */
+#define AMQP_BASIC_DELIVERY_MODE_FLAG \
+ (1 << 12) /**< basic.delivery-mode property flag */
+#define AMQP_BASIC_PRIORITY_FLAG (1 << 11) /**< basic.priority property flag \
+ */
+#define AMQP_BASIC_CORRELATION_ID_FLAG \
+ (1 << 10) /**< basic.correlation-id property flag */
+#define AMQP_BASIC_REPLY_TO_FLAG (1 << 9) /**< basic.reply-to property flag */
+#define AMQP_BASIC_EXPIRATION_FLAG \
+ (1 << 8) /**< basic.expiration property flag */
+#define AMQP_BASIC_MESSAGE_ID_FLAG \
+ (1 << 7) /**< basic.message-id property flag */
+#define AMQP_BASIC_TIMESTAMP_FLAG (1 << 6) /**< basic.timestamp property flag \
+ */
+#define AMQP_BASIC_TYPE_FLAG (1 << 5) /**< basic.type property flag */
+#define AMQP_BASIC_USER_ID_FLAG (1 << 4) /**< basic.user-id property flag */
+#define AMQP_BASIC_APP_ID_FLAG (1 << 3) /**< basic.app-id property flag */
+#define AMQP_BASIC_CLUSTER_ID_FLAG \
+ (1 << 2) /**< basic.cluster-id property flag */
/** basic class properties */
typedef struct amqp_basic_properties_t_ {
amqp_flags_t _flags; /**< bit-mask of set fields */
@@ -881,6 +904,19 @@ typedef struct amqp_confirm_properties_t_ {
/* API functions for methods */
/**
+ * amqp_connection_update_secret
+ *
+ * @param [in] state connection state
+ * @param [in] channel the channel to do the RPC on
+ * @param [in] new_secret new_secret
+ * @param [in] reason reason
+ * @returns amqp_connection_update_secret_ok_t
+ */
+AMQP_EXPORT
+amqp_connection_update_secret_ok_t *AMQP_CALL amqp_connection_update_secret(
+ amqp_connection_state_t state, amqp_channel_t channel,
+ amqp_bytes_t new_secret, amqp_bytes_t reason);
+/**
* amqp_channel_open
*
* @param [in] state connection state