From bb5b30716f9c307c47f2660e67cfebf1434a0da1 Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Thu, 7 May 2009 13:25:34 +0100 Subject: Use amq.direct instead of the default exchange --- examples/amqp_consumer.c | 2 +- examples/amqp_producer.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'examples') diff --git a/examples/amqp_consumer.c b/examples/amqp_consumer.c index 3b347f5..2ce6707 100644 --- a/examples/amqp_consumer.c +++ b/examples/amqp_consumer.c @@ -97,7 +97,7 @@ int main(int argc, char const * const *argv) { hostname = argv[1]; port = atoi(argv[2]); - exchange = ""; //argv[3]; + exchange = "amq.direct"; //argv[3]; bindingkey = "test queue"; //argv[4]; conn = amqp_new_connection(); diff --git a/examples/amqp_producer.c b/examples/amqp_producer.c index ef270b1..89e56bf 100644 --- a/examples/amqp_producer.c +++ b/examples/amqp_producer.c @@ -33,7 +33,7 @@ static void send_batch(amqp_connection_state_t conn, for (i = 0; i < message_count; i++) { long long now = now_microseconds(); die_on_error(amqp_basic_publish(conn, - (amqp_bytes_t) {.len = 0}, + amqp_cstring_bytes("amq.direct"), amqp_cstring_bytes(queue_name), 0, 0, -- cgit v1.2.1