diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2012-01-27 20:15:31 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2012-01-27 20:15:31 +0000 |
| commit | bb3fe508f98ec31109f951fb059ee49746a36d48 (patch) | |
| tree | 0d6e4351925947b2a9092723b6b0b4ddda64e2a4 /qpid/java/tools | |
| parent | 41b4e58c9736967d2260755ac38793aea1ecce8f (diff) | |
| download | qpid-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')
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() { |
