Changeset 947c4c65230cc3cd178a403ff254a532acbc389c

Show
Ignore:
Timestamp:
04/22/11 15:03:16 (3 years ago)
Author:
Theo Schlossnagle <jesus@omniti.com>
git-committer:
Theo Schlossnagle <jesus@omniti.com> 1303484596 -0400
git-parent:

[52df36cf48e43011594be0fcf1ff400f0aaf41cb]

git-author:
Theo Schlossnagle <jesus@omniti.com> 1303484596 -0400
Message:

allow the durability of the inbound exchange to be configurable

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • src/java/com/omniti/reconnoiter/broker/RabbitBroker.java

    r52df36c r947c4c6  
    4949  private boolean exclusiveQueue; 
    5050  private boolean durableQueue; 
     51  private boolean durableExchange; 
    5152  private Constructor<UpdateListener> con; 
    5253 
     
    8081 
    8182    this.exchangeType = config.getMQParameter("exchangetype", "fanout"); 
     83    this.durableExchange = config.getMQParameter("durableexchange", "false").equals("true"); 
    8284    this.exchangeName = config.getMQParameter("exchange", "noit.firehose"); 
    8385    this.exclusiveQueue = config.getMQParameter("exclusivequeue", "false").equals("true"); 
     
    138140 
    139141    channel = conn.createChannel(); 
    140     boolean exclusive = false, durable = true, internal = false, 
    141             autoDelete = false; 
     142    boolean exclusive = false, internal = false, autoDelete = false; 
    142143    channel.exchangeDeclare(exchangeName, exchangeType, 
    143                             durable, autoDelete, internal, null); 
     144                            durableExchange, autoDelete, internal, null); 
    144145    autoDelete = true; 
    145146