Modified: incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingClient.java URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingClient.java?rev=593566&r1=593565&r2=593566&view=diff ============================================================================== --- incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingClient.java (original) +++ incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingClient.java Fri Nov 9 07:31:03 2007 @@ -93,13 +93,13 @@ if (_isUnique) { - log.debug("1 consumer per destination."); + log.debug(_noOfConsumers + " consumer per destination."); return _noOfConsumers; } else { - log.debug(_pingClientCount + " consumers per destination."); + log.debug((_pingClientCount * _noOfConsumers) + " consumers per destination."); return _pingClientCount * _noOfConsumers; }
Modified: incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingLatencyTestPerf.java URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingLatencyTestPerf.java?rev=593566&r1=593565&r2=593566&view=diff ============================================================================== --- incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingLatencyTestPerf.java (original) +++ incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingLatencyTestPerf.java Fri Nov 9 07:31:03 2007 @@ -25,6 +25,9 @@ import org.apache.log4j.Logger; +import org.apache.qpid.client.AMQSession; +import org.apache.qpid.client.message.AMQMessage; +import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.requestreply.PingPongProducer; import uk.co.thebadgerset.junit.extensions.TimingController; @@ -33,6 +36,7 @@ import javax.jms.JMSException; import javax.jms.Message; +import javax.jms.ObjectMessage; import java.util.Collections; import java.util.HashMap; @@ -242,7 +246,9 @@ public BatchedResultsListener(int batchSize) { _batchSize = batchSize; - _strictAMQP = false; + _strictAMQP = + Boolean.parseBoolean(System.getProperties().getProperty(AMQSession.STRICT_AMQP, + AMQSession.STRICT_AMQP_DEFAULT)); } /**
