Author: rajikak
Date: Sun Aug 4 02:39:30 2013
New Revision: 1510090
URL: http://svn.apache.org/r1510090
Log:
fixed the consumer client.
Modified:
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java
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/AMQPConsumerClient.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java?rev=1510090&r1=1510089&r2=1510090&view=diff
==============================================================================
---
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java
(original)
+++
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java
Sun Aug 4 02:39:30 2013
@@ -22,8 +22,9 @@ public class AMQPConsumerClient {
System.out.println("Usage: java AMQPConsumerClient <queue-name>");
System.out.println("Default arguments will be used");
queueName = QUEUE_NAME;
+ } else {
+ queueName = args[1];
}
- queueName = args[1];
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
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=1510090&r1=1510089&r2=1510090&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:39:30 2013
@@ -90,7 +90,9 @@ public class AMQPProducerClient {
private static void produce(String message, Channel channel, String
queueName)
throws IOException {
- channel.basicPublish("", queueName, null, message.getBytes());
+ for (int i = 0; i < 1000000; i++) {
+ channel.basicPublish("", queueName, null, message.getBytes());
+ }
}
private static void publish(String message, Channel channel, String
exchangeName)
