From a52845a4c2c0bee52e72231e41c04f2c4a3f7eb4 Mon Sep 17 00:00:00 2001
From: "selva.andre" <selva.andre@gmail.com>
Date: Tue, 4 Sep 2012 13:58:33 +0200
Subject: [PATCH] Parametrized the code for benchmark Producers

---
 .../src/main/java/org/dna/mqtt/bechnmark/Main.java         | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Main.java b/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Main.java
index 197c6c71..2c7df518 100644
--- a/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Main.java
+++ b/benchmarking/src/main/java/org/dna/mqtt/bechnmark/Main.java
@@ -24,9 +24,10 @@ public class Main {
         //force wait to let the consumer be registered before the producer
         Thread.sleep(1000);
         int len = Producer.PUB_LOOP / NUM_CONCURRENT_PRODS;
-        producerPool.submit(new Producer("Prod1", 0, len));
-        producerPool.submit(new Producer("Prod2", len, len));
-        
+        for (int i = 0; i < NUM_CONCURRENT_PRODS; i++) {
+            producerPool.submit(new Producer("Prod " + i, i * len, len));
+        }
+
         consumerPool.shutdown();
         producerPool.shutdown();
     }