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;