summaryrefslogtreecommitdiff
path: root/librabbitmq/amqp_api.c
diff options
context:
space:
mode:
authorTony Garnock-Jones <tonygarnockjones@gmail.com>2010-06-05 17:38:53 +1200
committerTony Garnock-Jones <tonygarnockjones@gmail.com>2010-06-05 17:38:53 +1200
commit5ed71b2eb29e3cdb6c9efdcd06b155f4bfadf053 (patch)
tree471454aa78f9ce96bd81b7094e4c2b4dcec1d4c6 /librabbitmq/amqp_api.c
parent418c60dd1217822c5e399536ea1747607b957e30 (diff)
downloadrabbitmq-c-github-ask-5ed71b2eb29e3cdb6c9efdcd06b155f4bfadf053.tar.gz
Added amqp_queue_delete to API
Diffstat (limited to 'librabbitmq/amqp_api.c')
-rw-r--r--librabbitmq/amqp_api.c13
1 files changed, 13 insertions, 0 deletions
diff --git a/librabbitmq/amqp_api.c b/librabbitmq/amqp_api.c
index 91b0bf8..a748f90 100644
--- a/librabbitmq/amqp_api.c
+++ b/librabbitmq/amqp_api.c
@@ -189,6 +189,19 @@ amqp_queue_declare_ok_t *amqp_queue_declare(amqp_connection_state_t state,
return RPC_REPLY(amqp_queue_declare_ok_t);
}
+amqp_queue_delete_ok_t *amqp_queue_delete(amqp_connection_state_t state,
+ amqp_channel_t channel,
+ amqp_bytes_t queue,
+ amqp_boolean_t if_unused,
+ amqp_boolean_t if_empty)
+{
+ state->most_recent_api_result =
+ AMQP_SIMPLE_RPC(state, channel, QUEUE, DELETE, DELETE_OK,
+ amqp_queue_delete_t,
+ 0, queue, if_unused, if_empty, 0);
+ return RPC_REPLY(amqp_queue_delete_ok_t);
+}
+
amqp_queue_bind_ok_t *amqp_queue_bind(amqp_connection_state_t state,
amqp_channel_t channel,
amqp_bytes_t queue,