summaryrefslogtreecommitdiff
path: root/examples/amqp_exchange_declare.c
diff options
context:
space:
mode:
authorTony Garnock-Jones <tonyg@kcbbs.gen.nz>2009-05-07 00:40:43 +0100
committerTony Garnock-Jones <tonyg@kcbbs.gen.nz>2009-05-07 00:40:43 +0100
commita32fbd1ba39ab1ba9d1e798b1065b59f7f755267 (patch)
treec850e708249c3305ecdaa5a736ee9fa705a63453 /examples/amqp_exchange_declare.c
parentdc04434f7398528ef69954f0f840ac9ce5847347 (diff)
downloadrabbitmq-c-github-ask-a32fbd1ba39ab1ba9d1e798b1065b59f7f755267.tar.gz
Introduce more mid-level API
Diffstat (limited to 'examples/amqp_exchange_declare.c')
-rw-r--r--examples/amqp_exchange_declare.c20
1 files changed, 3 insertions, 17 deletions
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");