From 87791963b696d3f881ba2a7d7f1df15be14cb34d Mon Sep 17 00:00:00 2001
From: andrea <andrea@samarcanda>
Date: Wed, 29 Aug 2012 21:46:47 +0200
Subject: [PATCH] Defined constant for client's number of messages published

---
 .../src/main/java/org/dna/mqtt/bechnmark/Consumer.java        | 4 +---
 .../src/main/java/org/dna/mqtt/bechnmark/Producer.java        | 2 +-
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git a/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Consumer.java b/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Consumer.java
index d2670423..2c9f1a90 100644
--- a/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Consumer.java
+++ b/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Consumer.java
@@ -15,8 +15,6 @@ import org.slf4j.LoggerFactory;
  */
 public class Consumer implements Runnable {
     
-    static final int PUB_LOOP = 10000;
-    
     private static final Logger LOG = LoggerFactory.getLogger(Consumer.class);
     
     private String m_clientID;
@@ -54,7 +52,7 @@ public class Consumer implements Runnable {
         }
             
         Message message = null;
-        for (int i = 0; i < PUB_LOOP; i++) {
+        for (int i = 0; i < Producer.PUB_LOOP; i++) {
             try {
                 message = connection.receive();
             } catch (Exception ex) {
diff --git a/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Producer.java b/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Producer.java
index 4a82dfdd..a0e879dc 100644
--- a/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Producer.java
+++ b/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Producer.java
@@ -19,7 +19,7 @@ public class Producer implements Runnable {
     
     private String m_clientID;
     
-    static final int PUB_LOOP = 10000;
+    public static final int PUB_LOOP = 1000000;
     
     public Producer(String clientID) {
         m_clientID = clientID;