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);