summaryrefslogtreecommitdiff
path: root/qpid/java/tools
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2012-01-27 20:15:31 +0000
committerRobert Godfrey <rgodfrey@apache.org>2012-01-27 20:15:31 +0000
commitbb3fe508f98ec31109f951fb059ee49746a36d48 (patch)
tree0d6e4351925947b2a9092723b6b0b4ddda64e2a4 /qpid/java/tools
parent41b4e58c9736967d2260755ac38793aea1ecce8f (diff)
downloadqpid-python-bb3fe508f98ec31109f951fb059ee49746a36d48.tar.gz
NO-JIRA: Encapsulate fields, use private members and accesors (keep checkstyle happy)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1236867 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/tools')
-rw-r--r--qpid/java/tools/src/main/java/org/apache/qpid/testkit/Receiver.java14
-rw-r--r--qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java4
-rw-r--r--qpid/java/tools/src/main/java/org/apache/qpid/tools/LatencyTest.java36
3 files changed, 27 insertions, 27 deletions
diff --git a/qpid/java/tools/src/main/java/org/apache/qpid/testkit/Receiver.java b/qpid/java/tools/src/main/java/org/apache/qpid/testkit/Receiver.java
index b4294ee4cc..8dcf59e9c1 100644
--- a/qpid/java/tools/src/main/java/org/apache/qpid/testkit/Receiver.java
+++ b/qpid/java/tools/src/main/java/org/apache/qpid/testkit/Receiver.java
@@ -70,13 +70,13 @@ import org.apache.qpid.client.AMQConnection;
*/
public class Receiver extends Client implements MessageListener
{
- long msg_count = 0;
- int sequence = 0;
- boolean syncRcv = Boolean.getBoolean("sync_rcv");
- boolean jmsDurableSub = Boolean.getBoolean("jms_durable_sub");
- boolean checkForDups = Boolean.getBoolean("check_for_dups");
- MessageConsumer consumer;
- List<Integer> duplicateMessages = new ArrayList<Integer>();
+ private long msg_count = 0;
+ private int sequence = 0;
+ private boolean syncRcv = Boolean.getBoolean("sync_rcv");
+ private boolean jmsDurableSub = Boolean.getBoolean("jms_durable_sub");
+ private boolean checkForDups = Boolean.getBoolean("check_for_dups");
+ private MessageConsumer consumer;
+ private List<Integer> duplicateMessages = new ArrayList<Integer>();
public Receiver(Connection con,String addr) throws Exception
{
diff --git a/qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java b/qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java
index 2390516ef0..c604b24408 100644
--- a/qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java
+++ b/qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java
@@ -70,8 +70,8 @@ public class JNDICheck
private static String JAVA_NAMING = "java.naming.factory.initial";
- Context _context = null;
- Hashtable _environment = null;
+ private Context _context = null;
+ private Hashtable _environment = null;
public JNDICheck(String propertyFile)
{
diff --git a/qpid/java/tools/src/main/java/org/apache/qpid/tools/LatencyTest.java b/qpid/java/tools/src/main/java/org/apache/qpid/tools/LatencyTest.java
index 90ee7e28ae..16149d17c9 100644
--- a/qpid/java/tools/src/main/java/org/apache/qpid/tools/LatencyTest.java
+++ b/qpid/java/tools/src/main/java/org/apache/qpid/tools/LatencyTest.java
@@ -56,24 +56,24 @@ import org.apache.qpid.thread.Threading;
public class LatencyTest extends PerfBase implements MessageListener
{
- MessageProducer producer;
- MessageConsumer consumer;
- Message msg;
- byte[] payload;
- long maxLatency = 0;
- long minLatency = Long.MAX_VALUE;
- long totalLatency = 0; // to calculate avg latency.
- int rcvdMsgCount = 0;
- double stdDev = 0;
- double avgLatency = 0;
- boolean warmup_mode = true;
- boolean transacted = false;
- int transSize = 0;
-
- final List<Long> latencies;
- final Lock lock = new ReentrantLock();
- final Condition warmedUp;
- final Condition testCompleted;
+ private MessageProducer producer;
+ private MessageConsumer consumer;
+ private Message msg;
+ private byte[] payload;
+ private long maxLatency = 0;
+ private long minLatency = Long.MAX_VALUE;
+ private long totalLatency = 0; // to calculate avg latency.
+ private int rcvdMsgCount = 0;
+ private double stdDev = 0;
+ private double avgLatency = 0;
+ private boolean warmup_mode = true;
+ private boolean transacted = false;
+ private int transSize = 0;
+
+ private final List<Long> latencies;
+ private final Lock lock = new ReentrantLock();
+ private final Condition warmedUp;
+ private final Condition testCompleted;
public LatencyTest()
{