Changeset a03ab647d8bab40fd5c272d7981b58069f3fc781

Show
Ignore:
Timestamp:
11/24/10 19:15:05 (2 years ago)
Author:
Theo Schlossnagle <jesus@omniti.com>
git-committer:
Theo Schlossnagle <jesus@omniti.com> 1290626105 +0000
git-parent:

[fa18f5a78ce5d7f7e0ae42e2f6f38452b2716d16]

git-author:
Theo Schlossnagle <jesus@omniti.com> 1290626105 +0000
Message:

If no queue name was declared and one was subsequently auto-generated by
RabbitMQ, we'd replace the delcared queuename with the auto-generated one
and thereby destroy our future changes of establishing a queue on
the reconnect-after-failure case as we'd attempt to explicitly establish
a reserved auto-generated queue name.

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • src/java/com/omniti/reconnoiter/broker/RabbitBroker.java

    r6279a55 ra03ab64  
    3535  private String exchangeName; 
    3636  private String exchangeType; 
     37  private String declaredQueueName; 
    3738  private String queueName; 
    3839  private String routingKey; 
    …… 
    6768    this.exchangeType = config.getMQParameter("exchangetype", "fanout"); 
    6869    this.exchangeName = config.getMQParameter("exchange", "noit.firehose"); 
    69     this.queueName = config.getMQParameter("queue", ""); 
     70    this.declaredQueueName = config.getMQParameter("queue", ""); 
    7071    this.routingKey = config.getMQParameter("routingkey", ""); 
    7172   
    …… 
    102103    channel.exchangeDeclare(exchangeName, exchangeType, passive, durable, autoDelete, null); 
    103104    exclusive = true; autoDelete = true; 
    104     queueName = channel.queueDeclare(queueName, passive, durable, exclusive, autoDelete, null).getQueue(); 
     105    queueName = channel.queueDeclare(declaredQueueName, passive, durable, exclusive, autoDelete, null).getQueue(); 
    105106    channel.queueBind(queueName, exchangeName, routingKey); 
    106107    if(!routingKey.equals(""))