Changeset 947c4c65230cc3cd178a403ff254a532acbc389c
- Timestamp:
- 04/22/11 15:03:16
(2 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
| r52df36c |
r947c4c6 |
|
| 49 | 49 | private boolean exclusiveQueue; |
|---|
| 50 | 50 | private boolean durableQueue; |
|---|
| | 51 | private boolean durableExchange; |
|---|
| 51 | 52 | private Constructor<UpdateListener> con; |
|---|
| 52 | 53 | |
|---|
| … | … | |
| 80 | 81 | |
|---|
| 81 | 82 | this.exchangeType = config.getMQParameter("exchangetype", "fanout"); |
|---|
| | 83 | this.durableExchange = config.getMQParameter("durableexchange", "false").equals("true"); |
|---|
| 82 | 84 | this.exchangeName = config.getMQParameter("exchange", "noit.firehose"); |
|---|
| 83 | 85 | this.exclusiveQueue = config.getMQParameter("exclusivequeue", "false").equals("true"); |
|---|
| … | … | |
| 138 | 140 | |
|---|
| 139 | 141 | channel = conn.createChannel(); |
|---|
| 140 | | boolean exclusive = false, durable = true, internal = false, |
|---|
| 141 | | autoDelete = false; |
|---|
| | 142 | boolean exclusive = false, internal = false, autoDelete = false; |
|---|
| 142 | 143 | channel.exchangeDeclare(exchangeName, exchangeType, |
|---|
| 143 | | durable |
|---|
| | 144 | durableExchange, autoDelete, internal, null); |
|---|
| 144 | 145 | autoDelete = true; |
|---|
| 145 | 146 | |
|---|
