Author: rajikak
Date: Sun Aug  4 02:19:12 2013
New Revision: 1510089

URL: http://svn.apache.org/r1510089
Log:
used the passed queue name.

Modified:
    
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPProducerClient.java

Modified: 
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPProducerClient.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPProducerClient.java?rev=1510089&r1=1510088&r2=1510089&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPProducerClient.java
 (original)
+++ 
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPProducerClient.java
 Sun Aug  4 02:19:12 2013
@@ -74,7 +74,7 @@ public class AMQPProducerClient {
         }
 
         if (queueName != null) {
-            AMQPProducerClient.produce(MESSAGE2, channel, QUEUE_NAME);
+            AMQPProducerClient.produce(MESSAGE2, channel, queueName);
         } else {
             if (routingKey != null) {
                 AMQPProducerClient.route(MESSAGE2, channel, exchangeName, 
routingKey);


Reply via email to