summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2010-09-30 18:07:55 +0100
committerAlexandru Scvortov <alexandru@rabbitmq.com>2010-09-30 18:07:55 +0100
commit82cde63b968943055920af19bc23ae3ce3c7ef8f (patch)
treece50bf297321e781c49147a896f9e8fbac5b3ada
parent5b41470ca661d528dbafadb5865eaaa2a4342c21 (diff)
downloadrabbitmq-c-github-ask-bug23318.tar.gz
expose confirm.select in APIbug23318
-rw-r--r--librabbitmq/amqp_api.c12
1 files changed, 12 insertions, 0 deletions
diff --git a/librabbitmq/amqp_api.c b/librabbitmq/amqp_api.c
index b2793ff..c183acd 100644
--- a/librabbitmq/amqp_api.c
+++ b/librabbitmq/amqp_api.c
@@ -346,6 +346,18 @@ amqp_tx_rollback_ok_t *amqp_tx_rollback(amqp_connection_state_t state,
return RPC_REPLY(amqp_tx_rollback_ok_t);
}
+amqp_confirm_select_ok_t *amqp_confirm_select(amqp_connection_state_t state,
+ amqp_channel_t channel,
+ amqp_boolean_t multiple,
+ amqp_boolean_t no_wait)
+{
+ state->most_recent_api_result =
+ AMQP_SIMPLE_RPC(state, channel, CONFIRM, SELECT, SELECT_OK,
+ amqp_confirm_select_t,
+ multiple, no_wait);
+ return RPC_REPLY(amqp_tx_select_ok_t);
+}
+
amqp_rpc_reply_t amqp_get_rpc_reply(amqp_connection_state_t state)
{
return state->most_recent_api_result;