Author: jesus
Date: 2010-09-16 10:06:36 -0400 (Thu, 16 Sep 2010)
New Revision: 1458

Modified:
   trunk/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java
Log:
fixes #316

Modified: trunk/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java
===================================================================
--- trunk/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java	2010-09-15 22:32:15 UTC (rev 1457)
+++ trunk/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java	2010-09-16 14:06:36 UTC (rev 1458)
@@ -66,7 +66,7 @@
 
     this.exchangeType = config.getMQParameter("exchangetype", "fanout");
     this.exchangeName = config.getMQParameter("exchange", "noit.firehose");
-    this.queueName = config.getMQParameter("queue", "noit.firehose");
+    this.queueName = config.getMQParameter("queue", "");
     this.routingKey = config.getMQParameter("routingkey", "");
   
     this.alertRoutingKey = config.getBrokerParameter("routingkey", "noit.alerts.");
@@ -95,8 +95,8 @@
     channel = conn.createChannel();
     boolean passive = false, exclusive = false, durable = false, autoDelete = false;
     channel.exchangeDeclare(exchangeName, exchangeType, passive, durable, autoDelete, null);
-    autoDelete = true;
-    channel.queueDeclare(queueName, passive, durable, exclusive, autoDelete, null);
+    exclusive = true; autoDelete = true;
+    queueName = channel.queueDeclare(queueName, passive, durable, exclusive, autoDelete, null).getQueue();
     channel.queueBind(queueName, exchangeName, routingKey);
     if(!routingKey.equals(""))
       channel.queueBind(queueName, exchangeName, "");