Changeset 975

Timestamp:

11/28/13 09:32:16 (10 years ago)

Author:

jripsl

Message:

• remove RabbitMQ entities creation from the producer.

File:

• trunk/Monitoring/CNClient/send_AMQP_msg.c (modified) (1 diff)

trunk/Monitoring/CNClient/send_AMQP_msg.c

@@ -388 +388 @@
   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); // 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");
-
-  amqp_queue_declare(conn, 1, amqp_cstring_bytes("myqueue"), 0, 1, 0, 0, amqp_empty_table); // durable && no auto-delete
-  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("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");
+  // old 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");
+
+  //amqp_queue_declare(conn, 1, amqp_cstring_bytes("myqueue"), 0, 1, 0, 0, amqp_empty_table); // durable && no auto-delete
+  //die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring queue");
+
+  // old 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");
 
   {