summaryrefslogtreecommitdiff
path: root/librabbitmq/amqp.h
diff options
context:
space:
mode:
authorDavid Wragg <david@rabbitmq.com>2011-01-14 01:32:12 +0000
committerDavid Wragg <david@rabbitmq.com>2011-01-14 01:32:12 +0000
commit61f1fc5ae633b9e5509e741e90d3aece37bc8f87 (patch)
treed07d1cf89614c5216d483ccede59ee61100223df /librabbitmq/amqp.h
parent68e635a59583da19d7289be2eac040cf4eff328b (diff)
downloadrabbitmq-c-github-ask-61f1fc5ae633b9e5509e741e90d3aece37bc8f87.tar.gz
Extract common code from generated API functionsbug23645
Diffstat (limited to 'librabbitmq/amqp.h')
-rw-r--r--librabbitmq/amqp.h38
1 files changed, 22 insertions, 16 deletions
diff --git a/librabbitmq/amqp.h b/librabbitmq/amqp.h
index 49eaf3f..996372a 100644
--- a/librabbitmq/amqp.h
+++ b/librabbitmq/amqp.h
@@ -319,6 +319,28 @@ RABBITMQ_EXPORT amqp_rpc_reply_t amqp_simple_rpc(amqp_connection_state_t state,
amqp_method_number_t *expected_reply_ids,
void *decoded_request_method);
+RABBITMQ_EXPORT void *amqp_simple_rpc_decoded(amqp_connection_state_t state,
+ amqp_channel_t channel,
+ amqp_method_number_t request_id,
+ amqp_method_number_t reply_id,
+ void *decoded_request_method);
+
+/*
+ * The API methods corresponding to most synchronous AMQP methods
+ * return a pointer to the decoded method result. Upon error, they
+ * return NULL, and we need some way of discovering what, if anything,
+ * went wrong. amqp_get_rpc_reply() returns the most recent
+ * amqp_rpc_reply_t instance corresponding to such an API operation
+ * for the given connection.
+ *
+ * Only use it for operations that do not themselves return
+ * amqp_rpc_reply_t; operations that do return amqp_rpc_reply_t
+ * generally do NOT update this per-connection-global amqp_rpc_reply_t
+ * instance.
+ */
+RABBITMQ_EXPORT amqp_rpc_reply_t amqp_get_rpc_reply(
+ amqp_connection_state_t state);
+
RABBITMQ_EXPORT amqp_rpc_reply_t amqp_login(amqp_connection_state_t state,
char const *vhost,
int channel_max,
@@ -370,22 +392,6 @@ RABBITMQ_EXPORT amqp_boolean_t amqp_data_in_buffer(
amqp_connection_state_t state);
/*
- * For those API operations (such as amqp_basic_ack,
- * amqp_queue_declare, and so on) that do not themselves return
- * amqp_rpc_reply_t instances, we need some way of discovering what,
- * if anything, went wrong. amqp_get_rpc_reply() returns the most
- * recent amqp_rpc_reply_t instance corresponding to such an API
- * operation for the given connection.
- *
- * Only use it for operations that do not themselves return
- * amqp_rpc_reply_t; operations that do return amqp_rpc_reply_t
- * generally do NOT update this per-connection-global amqp_rpc_reply_t
- * instance.
- */
-RABBITMQ_EXPORT amqp_rpc_reply_t amqp_get_rpc_reply(
- amqp_connection_state_t state);
-
-/*
* Get the error string for the given error code.
*
* The returned string resides on the heap; the caller is responsible