[Reconnoiter-devel] [reconnoiter commit] Reconnoiter branch, master, updated. 52df36cf48e43011594be0fcf1ff400f0aaf41cb

git at labs.omniti.com git at labs.omniti.com
Fri Apr 22 10:48:48 EDT 2011


This is an automated email from the git hooks/post-receive script. It was
generated because a ref change was pushed to the repository containing
the project "Reconnoiter".

The branch, master has been updated
       via  52df36cf48e43011594be0fcf1ff400f0aaf41cb (commit)
      from  f0114718cabb08f0487ff82261a4a07b409e899f (commit)

Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.

- Log -----------------------------------------------------------------
commit 52df36cf48e43011594be0fcf1ff400f0aaf41cb
Author: Theo Schlossnagle <jesus at omniti.com>
Date:   Fri Apr 22 10:48:45 2011 -0400

    these apply to the MQ we're *listening* to which is described in the mq section

diff --git a/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java b/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java
index 6aa46b3..f3f6124 100644
--- a/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java
+++ b/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java
@@ -61,8 +61,6 @@ public class RabbitBroker implements IMQBroker  {
     this.portNumber = Integer.parseInt(config.getBrokerParameter("port", "5672"));
     this.heartBeat = Integer.parseInt(config.getBrokerParameter("heartbeat", "5000"));
     this.heartBeat = (this.heartBeat + 999) / 1000; // (ms -> seconds, rounding up)
-    this.exclusiveQueue = config.getBrokerParameter("exclusivequeue", "false").equals("true");
-    this.durableQueue = config.getBrokerParameter("durablequeue", "false").equals("true");
     this.connectTimeout = Integer.parseInt(config.getBrokerParameter("connect_timeout", "5000"));
     
     String className = config.getBrokerParameter("listenerClass", "com.omniti.reconnoiter.broker.RabbitListener");
@@ -82,6 +80,8 @@ public class RabbitBroker implements IMQBroker  {
 
     this.exchangeType = config.getMQParameter("exchangetype", "fanout");
     this.exchangeName = config.getMQParameter("exchange", "noit.firehose");
+    this.exclusiveQueue = config.getMQParameter("exclusivequeue", "false").equals("true");
+    this.durableQueue = config.getMQParameter("durablequeue", "false").equals("true");
     this.declaredQueueName = config.getMQParameter("queue", "reconnoiter-{node}-{pid}");
     this.routingKey = config.getMQParameter("routingkey", "");
   

-----------------------------------------------------------------------

Summary of changes:
 .../omniti/reconnoiter/broker/RabbitBroker.java    |    4 ++--
 1 files changed, 2 insertions(+), 2 deletions(-)


hooks/post-receive
-- 
Reconnoiter


More information about the Reconnoiter-devel mailing list