[Reconnoiter-devel] [reconnoiter commit] Reconnoiter branch, master, updated. 947c4c65230cc3cd178a403ff254a532acbc389c

git at labs.omniti.com git at labs.omniti.com
Fri Apr 22 11:03:20 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  947c4c65230cc3cd178a403ff254a532acbc389c (commit)
      from  52df36cf48e43011594be0fcf1ff400f0aaf41cb (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 947c4c65230cc3cd178a403ff254a532acbc389c
Author: Theo Schlossnagle <jesus at omniti.com>
Date:   Fri Apr 22 11:03:16 2011 -0400

    allow the durability of the inbound exchange to be configurable

diff --git a/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java b/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java
index f3f6124..baf51b4 100644
--- a/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java
+++ b/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java
@@ -48,6 +48,7 @@ public class RabbitBroker implements IMQBroker  {
   private Class listenerClass;
   private boolean exclusiveQueue;
   private boolean durableQueue;
+  private boolean durableExchange;
   private Constructor<UpdateListener> con;
 
   @SuppressWarnings("unchecked") 
@@ -79,6 +80,7 @@ public class RabbitBroker implements IMQBroker  {
     }
 
     this.exchangeType = config.getMQParameter("exchangetype", "fanout");
+    this.durableExchange = config.getMQParameter("durableexchange", "false").equals("true");
     this.exchangeName = config.getMQParameter("exchange", "noit.firehose");
     this.exclusiveQueue = config.getMQParameter("exclusivequeue", "false").equals("true");
     this.durableQueue = config.getMQParameter("durablequeue", "false").equals("true");
@@ -137,10 +139,9 @@ public class RabbitBroker implements IMQBroker  {
     if(conn == null) throw new Exception("connection failed");
 
     channel = conn.createChannel();
-    boolean exclusive = false, durable = true, internal = false,
-            autoDelete = false;
+    boolean exclusive = false, internal = false, autoDelete = false;
     channel.exchangeDeclare(exchangeName, exchangeType,
-                            durable, autoDelete, internal, null);
+                            durableExchange, autoDelete, internal, null);
     autoDelete = true;
 
     returnedQueueName = channel.queueDeclare(queueName, durableQueue,

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

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


hooks/post-receive
-- 
Reconnoiter


More information about the Reconnoiter-devel mailing list