diff options
Diffstat (limited to 'librabbitmq/amqp_api.c')
| -rw-r--r-- | librabbitmq/amqp_api.c | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/librabbitmq/amqp_api.c b/librabbitmq/amqp_api.c index a3c8839..8adf3f0 100644 --- a/librabbitmq/amqp_api.c +++ b/librabbitmq/amqp_api.c @@ -198,3 +198,36 @@ int amqp_basic_ack(amqp_connection_state_t state, AMQP_CHECK_RESULT(amqp_send_method(state, channel, AMQP_BASIC_ACK_METHOD, &m)); return 0; } + +amqp_queue_purge_ok_t *amqp_queue_purge(amqp_connection_state_t state, + amqp_channel_t channel, + amqp_bytes_t queue, + amqp_boolean_t no_wait) +{ + amqp_rpc_reply = AMQP_SIMPLE_RPC(state, channel, QUEUE, PURGE, PURGE_OK, + amqp_queue_purge_t, channel, queue, no_wait); + return RPC_REPLY(amqp_queue_purge_ok_t); +} + +amqp_rpc_reply_t amqp_basic_get(amqp_connection_state_t state, + amqp_channel_t channel, + amqp_bytes_t queue, + amqp_boolean_t no_ack) +{ + amqp_method_number_t replies[] = { AMQP_BASIC_GET_OK_METHOD, + AMQP_BASIC_GET_EMPTY_METHOD, + 0 }; + amqp_rpc_reply = + AMQP_MULTIPLE_RESPONSE_RPC(state, channel, BASIC, GET, replies, + amqp_basic_get_t, + channel, queue, no_ack); + return amqp_rpc_reply; +} + +/* + * Expose amqp_rpc_reply to dynamically linked libraries + */ +amqp_rpc_reply_t amqp_get_rpc_reply(void) +{ + return amqp_rpc_reply; +} |