Author: rajikak
Date: Sun Aug 4 02:40:04 2013
New Revision: 1510091
URL: http://svn.apache.org/r1510091
Log:
reverted the invalid commit.
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=1510091&r1=1510090&r2=1510091&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:40:04 2013
@@ -90,9 +90,7 @@ public class AMQPProducerClient {
private static void produce(String message, Channel channel, String
queueName)
throws IOException {
- for (int i = 0; i < 1000000; i++) {
- channel.basicPublish("", queueName, null, message.getBytes());
- }
+ channel.basicPublish("", queueName, null, message.getBytes());
}
private static void publish(String message, Channel channel, String
exchangeName)
