Changeset a2f3c05a332f6b42643501a7abdadf98e2a268d7

Show
Ignore:
Timestamp:
03/21/12 21:15:58 (2 years ago)
Author:
Brian Clapper <bclapper@omniti.com>
git-committer:
Brian Clapper <bclapper@omniti.com> 1332364558 -0400
git-parent:

[b1b5fc0fee416e9f1842b44b97dbb3c4e5a053fd]

git-author:
Brian Clapper <bclapper@omniti.com> 1332364558 -0400
Message:

need a placeholder to be able to bind to the 'empty' routingkey

Files:

Legend:

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

    rb1b5fc0 ra2f3c05  
    148148                                             exclusiveQueue, autoDelete, null).getQueue(); 
    149149    for (String rk : routingKey.split(",")) { 
     150        if ( rk.equalsIgnoreCase("null") ) rk = ""; 
    150151        channel.queueBind(returnedQueueName, exchangeName, rk); 
    151152    }