Changeset 971 for trunk/Monitoring/CNClient

Timestamp:

11/22/13 12:34:25 (11 years ago)

Author:

jripsl

Message:

• switch routing behaviour (switch exchange type from "fanout" to "direct" to use routing key).

File:

• trunk/Monitoring/CNClient/send_AMQP_msg.c (modified) (3 diffs)

trunk/Monitoring/CNClient/send_AMQP_msg.c

@@ -365 +365 @@
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
-  amqp_exchange_declare(conn, 1, amqp_cstring_bytes("myexchange"), amqp_cstring_bytes("fanout"), 0, 0, amqp_empty_table);
+  //amqp_exchange_declare(conn, 1, amqp_cstring_bytes("myexchange"), amqp_cstring_bytes("fanout"), 0, 0, amqp_empty_table); // fanout exchange (i.e. without routing key)
+  amqp_exchange_declare(conn, 1, amqp_cstring_bytes("myexchange"), amqp_cstring_bytes("direct"), 0, 0, amqp_empty_table); // direct exchange (i.e. to be used with routing key)
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring exchange");
 
@@ -371 +372 @@
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring queue");
 
-  amqp_queue_bind(conn, 1, amqp_cstring_bytes("myqueue"), amqp_cstring_bytes("myexchange"), amqp_cstring_bytes(""), amqp_empty_table); //no need for binding key as we use the fanout exchange type
+  //amqp_queue_bind(conn, 1, amqp_cstring_bytes("myqueue"), amqp_cstring_bytes("myexchange"), amqp_cstring_bytes(""), amqp_empty_table); //no need for binding key as we use the fanout exchange type
+  amqp_queue_bind(conn, 1, amqp_cstring_bytes("myqueue"), amqp_cstring_bytes("myexchange"), amqp_cstring_bytes("myroutingkey"), amqp_empty_table);   //we use a binding key here as we use the direct exchange type
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Binding");
 
@@ -382 +384 @@
 
     for (i = 0; i < msg_count; i++)
-      die_on_error(amqp_basic_publish(conn, 1, amqp_cstring_bytes("myexchange"), amqp_cstring_bytes(""), 0, 0, &props, amqp_cstring_bytes(body)), "Publishing");
+      die_on_error(amqp_basic_publish(conn, 1, amqp_cstring_bytes("myexchange"), amqp_cstring_bytes("myroutingkey"), 0, 0, &props, amqp_cstring_bytes(body)), "Publishing");
   }