diff --git a/test/broker/ptest.py b/test/broker/ptest.py
index b6b766fb..df029c1e 100755
--- a/test/broker/ptest.py
+++ b/test/broker/ptest.py
@@ -153,39 +153,23 @@ def next_test(tests, ports):
         return
 
     test = tests.pop()
-    if test[0] == 1:
-        port = ports.pop()
-        p = subprocess.Popen([test[1], str(port)])
-        p.start_time = time.time()
-        p.mosq_port = port
-        return p
-    elif test[0] == 2:
-        if len(ports) < 2:
-            tests.insert(0,test)
-            return None
-        else:
-            port1 = ports.pop()
-            port2 = ports.pop()
-
-            p = subprocess.Popen([test[1], str(port1), str(port2)])
-            p.start_time = time.time()
-            p.mosq_port = (port1, port2)
-            return p
-    elif test[0] == 3:
-        if len(ports) < 3:
-            tests.insert(0,test)
-            return None
-        else:
-            port1 = ports.pop()
-            port2 = ports.pop()
-            port3 = ports.pop()
-
-            p = subprocess.Popen([test[1], str(port1), str(port2), str(port3)])
-            p.start_time = time.time()
-            p.mosq_port = (port1, port2, port3)
-            return p
-    else:
+    proc_ports = ()
+
+    if len(ports) < test[0]:
+        tests.insert(0, test)
         return None
+    else:
+        args = [test[1]]
+
+        for i in range(0, test[0]):
+            proc_port = ports.pop()
+            proc_ports = proc_ports + (proc_port,)
+            args.append(str(proc_port))
+
+        proc = subprocess.Popen(args)
+        proc.start_time = time.time()
+        proc.mosq_port = proc_ports
+        return proc
 
 
 def run_tests(tests, ports):