make the routingKey binding more flexible (comma separated list)

philips · Mar 21, 2012 · 0be44ef · 0be44ef
1 parent 8a2fef6
commit 0be44ef
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java b/src/java/com/omniti/reconnoiter/broker/RabbitBroker.java
@@ -146,9 +146,9 @@ public void connect() throws Exception {
 
     returnedQueueName = channel.queueDeclare(queueName, durableQueue,
                                              exclusiveQueue, autoDelete, null).getQueue();
-    channel.queueBind(returnedQueueName, exchangeName, routingKey);
-    if(!routingKey.equals(""))
-      channel.queueBind(returnedQueueName, exchangeName, "");
+    for (String rk : routingKey.split(",")) {
+        channel.queueBind(returnedQueueName, exchangeName, rk);
+    }
   }
   public Channel getChannel() { return channel; }
 

diff --git a/src/stratcon.conf.in b/src/stratcon.conf.in
@@ -53,7 +53,7 @@
       <hostname>mq1.int.circonus.net,mq2.int.circonus.net</hostname>
       <exchange>noit.firehose</exchange>
       <exchangetype>topic</exchangetype>
-      <routingkey>check</routingkey>
+      <routingkey>check,</routingkey>
       <username>stratcon</username>
       <password>youllneverguess</password>
     </mq>