subhrajyotim / rocksteady

Automatically exported from code.google.com/p/rocksteady
GNU General Public License v2.0
0 stars 0 forks source link

in MessageManager.java exchangeDeclare pass wrong args #8

Open GoogleCodeExporter opened 8 years ago

GoogleCodeExporter commented 8 years ago
What steps will reproduce the problem?
1.run rocksteady
2.rabbitmqctl list_exchanges name  durable auto_delete

What is the expected output? What do you see instead?
in classes/META-INF/rocksteady.properties
rabbitDurable=true
rabbitAutoDelete=false
rabbitExchangeType=topic
while 
rabbitmqctl list_exchanges  durable auto_delete
always return  false false

What version of the product are you using? On what operating system?

1.0.0,debian 6,
Please provide any additional information below.

mqChannel.exchangeDeclare(rabbitExchange, rabbitExchangeType, false, 
rabbitDurable, rabbitAutoDelete, null);

please read
http://www.rabbitmq.com/javadoc/com/rabbitmq/client/Channel.html#exchangeDeclare
(java.lang.String, java.lang.String, boolean, boolean, boolean, java.util.Map)

Index: src/main/java/com/admob/rocksteady/router/MessageManager.java
===================================================================
--- src/main/java/com/admob/rocksteady/router/MessageManager.java       
(revision 118)
+++ src/main/java/com/admob/rocksteady/router/MessageManager.java       
(working copy)
@@ -169,7 +169,7 @@
       mqChannel = mqConnection.createChannel();
       // Now we have connection
       //mqChannel.exchangeDelete(rabbitExchange);
-      mqChannel.exchangeDeclare(rabbitExchange, rabbitExchangeType, false, 
rabbitDurable, rabbitAutoDelete, null);
+      mqChannel.exchangeDeclare(rabbitExchange, rabbitExchangeType, 
rabbitDurable, rabbitAutoDelete, false, null);

       // Add a random string to queue name so each instance of rocksteady will
       // have its own queue

Original issue reported on code.google.com by Guxian...@gmail.com on 8 Jun 2012 at 10:40