summaryrefslogtreecommitdiff
path: root/qpid/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
commit46ee32800c0d5477d8feb70f518816176360443c (patch)
tree377d689593d4cb10b5e09e8f0ab8839bc1b2a9e3 /qpid/java/perftests
parentf8a69b681aa852848c0b720481f45de8ca934f78 (diff)
downloadqpid-python-46ee32800c0d5477d8feb70f518816176360443c.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@1236647 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/perftests')
-rw-r--r--qpid/java/perftests/src/main/java/org/apache/qpid/config/Connector.java5
-rw-r--r--qpid/java/perftests/src/main/java/org/apache/qpid/oldtopic/Publisher.java5
2 files changed, 8 insertions, 2 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/config/Connector.java b/qpid/java/perftests/src/main/java/org/apache/qpid/config/Connector.java
index ff2377f087..81541a3260 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/config/Connector.java
+++ b/qpid/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/qpid/java/perftests/src/main/java/org/apache/qpid/oldtopic/Publisher.java b/qpid/java/perftests/src/main/java/org/apache/qpid/oldtopic/Publisher.java
index f811704323..841fcc63ad 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/oldtopic/Publisher.java
+++ b/qpid/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.");
}