summaryrefslogtreecommitdiff
path: root/java/perftests
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2012-01-27 12:19:57 +0000
committerRobert Godfrey <rgodfrey@apache.org>2012-01-27 12:19:57 +0000
commitfac38971d2943f7e7113ebaf1425ef731799d1f8 (patch)
tree80a2c48cb90eac58d86115b7ac8a8ac867510aca /java/perftests
parentadbaa8b9bb6629daecfdfb3efcaba24a485580ba (diff)
downloadqpid-python-fac38971d2943f7e7113ebaf1425ef731799d1f8.tar.gz
NO-JIRA: Ensure all control flow statements use braces (keeping CheckStyle happy)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1236647 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/perftests')
-rw-r--r--java/perftests/src/main/java/org/apache/qpid/config/Connector.java5
-rw-r--r--java/perftests/src/main/java/org/apache/qpid/oldtopic/Publisher.java5
2 files changed, 8 insertions, 2 deletions
diff --git a/java/perftests/src/main/java/org/apache/qpid/config/Connector.java b/java/perftests/src/main/java/org/apache/qpid/config/Connector.java
index ff2377f087..81541a3260 100644
--- a/java/perftests/src/main/java/org/apache/qpid/config/Connector.java
+++ b/java/perftests/src/main/java/org/apache/qpid/config/Connector.java
@@ -33,7 +33,10 @@ public class Connector
ConnectionFactory getConnectionFactory(ConnectorConfig config) throws Exception
{
String factory = config.getFactory();
- if(factory == null) factory = AMQConnectionFactoryInitialiser.class.getName();
+ if(factory == null)
+ {
+ factory = AMQConnectionFactoryInitialiser.class.getName();
+ }
System.out.println("Using " + factory);
return ((ConnectionFactoryInitialiser) Class.forName(factory).newInstance()).getFactory(config);
}
diff --git a/java/perftests/src/main/java/org/apache/qpid/oldtopic/Publisher.java b/java/perftests/src/main/java/org/apache/qpid/oldtopic/Publisher.java
index f811704323..841fcc63ad 100644
--- a/java/perftests/src/main/java/org/apache/qpid/oldtopic/Publisher.java
+++ b/java/perftests/src/main/java/org/apache/qpid/oldtopic/Publisher.java
@@ -61,7 +61,10 @@ public class Publisher implements MessageListener
long[] times = new long[batches];
for(int i = 0; i < batches; i++)
{
- if(i > 0) Thread.sleep(delay*1000);
+ if(i > 0)
+ {
+ Thread.sleep(delay*1000);
+ }
times[i] = batch(msgCount, consumerCount);
System.out.println("Batch " + (i+1) + " of " + batches + " completed in " + times[i] + " ms.");
}