From ccbc24d2709f6034e7858e6a72b92f6bfc86675f Mon Sep 17 00:00:00 2001 From: Alan Antonuk Date: Wed, 7 Aug 2013 11:25:00 -0700 Subject: Initial connection.blocked/unblocked support Add encode/decode support for connection.blocked, connection.unblocked RabbitMQ AMQP extension --- librabbitmq/amqp_framing.h | 10 ++++++++++ 1 file changed, 10 insertions(+) (limited to 'librabbitmq/amqp_framing.h') diff --git a/librabbitmq/amqp_framing.h b/librabbitmq/amqp_framing.h index f6dafe4..0c04cb8 100644 --- a/librabbitmq/amqp_framing.h +++ b/librabbitmq/amqp_framing.h @@ -183,6 +183,16 @@ typedef struct amqp_connection_close_ok_t_ { char dummy; /* Dummy field to avoid empty struct */ } amqp_connection_close_ok_t; +#define AMQP_CONNECTION_BLOCKED_METHOD ((amqp_method_number_t) 0x000A003C) /* 10, 60; 655420 */ +typedef struct amqp_connection_blocked_t_ { + amqp_bytes_t reason; +} amqp_connection_blocked_t; + +#define AMQP_CONNECTION_UNBLOCKED_METHOD ((amqp_method_number_t) 0x000A003D) /* 10, 61; 655421 */ +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) /* 20, 10; 1310730 */ typedef struct amqp_channel_open_t_ { amqp_bytes_t out_of_band; -- cgit v1.2.1