From a32fbd1ba39ab1ba9d1e798b1065b59f7f755267 Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Thu, 7 May 2009 00:40:43 +0100 Subject: Introduce more mid-level API --- examples/amqp_exchange_declare.c | 20 +++----------------- 1 file changed, 3 insertions(+), 17 deletions(-) (limited to 'examples/amqp_exchange_declare.c') 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"); -- cgit v1.2.1