@@ -77,7 +77,7 @@ public void noSharing() throws Exception {
7777 MulticastSet set = getMulticastSet ();
7878 params .setConsumerCount (10 );
7979 set .run ();
80- verify (threadingHandler , times (10 + 1 + 1 )) // for each consumer, for all producers, and one for each producer
80+ verify (threadingHandler , times (1 + 10 + 1 + 1 )) // for configuration, for each consumer, for all producers, and one for each producer
8181 .executorService (anyString (), anyInt ());
8282 }
8383
@@ -86,7 +86,7 @@ public void noSharing() throws Exception {
8686 params .setConsumerCount (10 );
8787 params .setConsumersThreadPools (5 );
8888 set .run ();
89- verify (threadingHandler , times (5 + 1 + 1 )) // for each consumer, for all producers, and one for each producer
89+ verify (threadingHandler , times (1 + 5 + 1 + 1 )) // for configuration, for each consumer, for all producers, and one for each producer
9090 .executorService (anyString (), anyInt ());
9191 }
9292
@@ -95,7 +95,7 @@ public void noSharing() throws Exception {
9595 params .setConsumerCount (5 );
9696 params .setConsumersThreadPools (10 );
9797 set .run ();
98- verify (threadingHandler , times (5 + 1 + 1 )) // for each consumer, for all producers, and one for each producer
98+ verify (threadingHandler , times (1 + 5 + 1 + 1 )) // for configuration, for each consumer, for all producers, and one for each producer
9999 .executorService (anyString (), anyInt ());
100100 }
101101
@@ -104,7 +104,7 @@ public void noSharing() throws Exception {
104104 params .setConsumerCount (20 );
105105 params .setConsumersThreadPools (6 );
106106 set .run ();
107- verify (threadingHandler , times (6 + 1 + 1 )) // for each consumer, for all producers, and one for each producer
107+ verify (threadingHandler , times (1 + 6 + 1 + 1 )) // for configuration, for each consumer, for all producers, and one for each producer
108108 .executorService (anyString (), anyInt ());
109109 }
110110
0 commit comments