diff options
author | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-05-07 00:40:43 +0100 |
---|---|---|
committer | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-05-07 00:40:43 +0100 |
commit | a32fbd1ba39ab1ba9d1e798b1065b59f7f755267 (patch) | |
tree | c850e708249c3305ecdaa5a736ee9fa705a63453 /examples | |
parent | dc04434f7398528ef69954f0f840ac9ce5847347 (diff) | |
download | rabbitmq-c-github-ask-a32fbd1ba39ab1ba9d1e798b1065b59f7f755267.tar.gz |
Introduce more mid-level API
Diffstat (limited to 'examples')
-rw-r--r-- | examples/amqp_consumer.c | 53 | ||||
-rw-r--r-- | examples/amqp_exchange_declare.c | 20 | ||||
-rw-r--r-- | examples/amqp_listen.c | 53 |
3 files changed, 19 insertions, 107 deletions
diff --git a/examples/amqp_consumer.c b/examples/amqp_consumer.c index 84c3669..3b347f5 100644 --- a/examples/amqp_consumer.c +++ b/examples/amqp_consumer.c @@ -88,7 +88,6 @@ int main(int argc, char const * const *argv) { int sockfd; amqp_connection_state_t conn; - amqp_rpc_reply_t result; amqp_bytes_t queuename; if (argc < 3) { @@ -109,57 +108,21 @@ int main(int argc, char const * const *argv) { "Logging in"); { - amqp_queue_declare_t s = - (amqp_queue_declare_t) { - .ticket = 0, - .queue = {.len = 0, .bytes = NULL}, - .passive = 0, - .durable = 0, - .exclusive = 0, - .auto_delete = 1, - .nowait = 0, - .arguments = {.num_entries = 0, .entries = NULL} - }; - die_on_amqp_error(result = amqp_simple_rpc(conn, 1, AMQP_QUEUE_DECLARE_METHOD, - AMQP_QUEUE_DECLARE_OK_METHOD, &s), - "Declaring queue"); - amqp_queue_declare_ok_t *r = (amqp_queue_declare_ok_t *) result.reply.decoded; + amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, AMQP_EMPTY_BYTES, 0, 0, 0, 1, + AMQP_EMPTY_TABLE); + die_on_amqp_error(amqp_rpc_reply, "Declaring queue"); queuename = amqp_bytes_malloc_dup(r->queue); if (queuename.bytes == NULL) { die_on_error(-ENOMEM, "Copying queue name"); } } - { - amqp_queue_bind_t s = - (amqp_queue_bind_t) { - .ticket = 0, - .queue = queuename, - .exchange = amqp_cstring_bytes(exchange), - .routing_key = amqp_cstring_bytes(bindingkey), - .nowait = 0, - .arguments = {.num_entries = 0, .entries = NULL} - }; - die_on_amqp_error(result = amqp_simple_rpc(conn, 1, AMQP_QUEUE_BIND_METHOD, - AMQP_QUEUE_BIND_OK_METHOD, &s), - "Binding queue"); - } + amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey), + AMQP_EMPTY_TABLE); + die_on_amqp_error(amqp_rpc_reply, "Binding queue"); - { - amqp_basic_consume_t s = - (amqp_basic_consume_t) { - .ticket = 0, - .queue = queuename, - .consumer_tag = {.len = 0, .bytes = NULL}, - .no_local = 0, - .no_ack = 1, - .exclusive = 0, - .nowait = 0 - }; - die_on_amqp_error(result = amqp_simple_rpc(conn, 1, AMQP_BASIC_CONSUME_METHOD, - AMQP_BASIC_CONSUME_OK_METHOD, &s), - "Consuming"); - } + amqp_basic_consume(conn, 1, queuename, AMQP_EMPTY_BYTES, 0, 1, 0); + die_on_amqp_error(amqp_rpc_reply, "Consuming"); run(conn); diff --git a/examples/amqp_exchange_declare.c b/examples/amqp_exchange_declare.c index d03290e..f163db1 100644 --- a/examples/amqp_exchange_declare.c +++ b/examples/amqp_exchange_declare.c @@ -36,23 +36,9 @@ int main(int argc, char const * const *argv) { die_on_amqp_error(amqp_login(conn, "/", 131072, AMQP_SASL_METHOD_PLAIN, "guest", "guest"), "Logging in"); - { - amqp_exchange_declare_t s = - (amqp_exchange_declare_t) { - .ticket = 0, - .exchange = amqp_cstring_bytes(exchange), - .type = amqp_cstring_bytes(exchangetype), - .passive = 0, - .durable = 0, - .auto_delete = 0, - .internal = 0, - .nowait = 0, - .arguments = {.num_entries = 0, .entries = NULL} - }; - die_on_amqp_error(amqp_simple_rpc(conn, 1, AMQP_EXCHANGE_DECLARE_METHOD, - AMQP_EXCHANGE_DECLARE_OK_METHOD, &s), - "Declaring exchange"); - } + amqp_exchange_declare(conn, 1, amqp_cstring_bytes(exchange), amqp_cstring_bytes(exchangetype), + 0, 0, 0, AMQP_EMPTY_TABLE); + die_on_amqp_error(amqp_rpc_reply, "Declaring exchange"); die_on_amqp_error(amqp_channel_close(conn, AMQP_REPLY_SUCCESS), "Closing channel"); die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection"); diff --git a/examples/amqp_listen.c b/examples/amqp_listen.c index f759183..3bbb341 100644 --- a/examples/amqp_listen.c +++ b/examples/amqp_listen.c @@ -24,7 +24,6 @@ int main(int argc, char const * const *argv) { int sockfd; amqp_connection_state_t conn; - amqp_rpc_reply_t result; amqp_bytes_t queuename; if (argc < 5) { @@ -45,57 +44,21 @@ int main(int argc, char const * const *argv) { "Logging in"); { - amqp_queue_declare_t s = - (amqp_queue_declare_t) { - .ticket = 0, - .queue = {.len = 0, .bytes = NULL}, - .passive = 0, - .durable = 0, - .exclusive = 0, - .auto_delete = 1, - .nowait = 0, - .arguments = {.num_entries = 0, .entries = NULL} - }; - die_on_amqp_error(result = amqp_simple_rpc(conn, 1, AMQP_QUEUE_DECLARE_METHOD, - AMQP_QUEUE_DECLARE_OK_METHOD, &s), - "Declaring queue"); - amqp_queue_declare_ok_t *r = (amqp_queue_declare_ok_t *) result.reply.decoded; + amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, AMQP_EMPTY_BYTES, 0, 0, 0, 1, + AMQP_EMPTY_TABLE); + die_on_amqp_error(amqp_rpc_reply, "Declaring queue"); queuename = amqp_bytes_malloc_dup(r->queue); if (queuename.bytes == NULL) { die_on_error(-ENOMEM, "Copying queue name"); } } - { - amqp_queue_bind_t s = - (amqp_queue_bind_t) { - .ticket = 0, - .queue = queuename, - .exchange = amqp_cstring_bytes(exchange), - .routing_key = amqp_cstring_bytes(bindingkey), - .nowait = 0, - .arguments = {.num_entries = 0, .entries = NULL} - }; - die_on_amqp_error(result = amqp_simple_rpc(conn, 1, AMQP_QUEUE_BIND_METHOD, - AMQP_QUEUE_BIND_OK_METHOD, &s), - "Binding queue"); - } + amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey), + AMQP_EMPTY_TABLE); + die_on_amqp_error(amqp_rpc_reply, "Binding queue"); - { - amqp_basic_consume_t s = - (amqp_basic_consume_t) { - .ticket = 0, - .queue = queuename, - .consumer_tag = {.len = 0, .bytes = NULL}, - .no_local = 0, - .no_ack = 1, - .exclusive = 0, - .nowait = 0 - }; - die_on_amqp_error(result = amqp_simple_rpc(conn, 1, AMQP_BASIC_CONSUME_METHOD, - AMQP_BASIC_CONSUME_OK_METHOD, &s), - "Consuming"); - } + amqp_basic_consume(conn, 1, queuename, AMQP_EMPTY_BYTES, 0, 1, 0); + die_on_amqp_error(amqp_rpc_reply, "Consuming"); { amqp_frame_t frame; |