File tree Expand file tree Collapse file tree 1 file changed +2
-7
lines changed
helper/src/main/java/com/hazelcast/examples/helper Expand file tree Collapse file tree 1 file changed +2
-7
lines changed Original file line number Diff line number Diff line change 1818
1919import com .hazelcast .core .HazelcastInstance ;
2020import com .hazelcast .instance .impl .HazelcastInstanceProxy ;
21- import com .hazelcast .internal .nio .EndpointManager ;
2221import com .hazelcast .internal .util .EmptyStatement ;
2322import com .hazelcast .internal .util .ExceptionUtil ;
2423
2827import java .util .Random ;
2928import java .util .concurrent .CountDownLatch ;
3029
31- import static com .hazelcast .examples .helper .HazelcastUtils .getNode ;
3230import static java .util .concurrent .TimeUnit .MILLISECONDS ;
3331import static java .util .concurrent .TimeUnit .NANOSECONDS ;
3432import static java .util .concurrent .TimeUnit .SECONDS ;
@@ -161,12 +159,9 @@ public static void sleepAtLeastMillis(long sleepFor) {
161159 public static void assertClusterSize (int expectedSize , HazelcastInstance instance ) {
162160 int clusterSize = instance .getCluster ().getMembers ().size ();
163161 if (expectedSize != clusterSize ) {
164- EndpointManager endpointManager = getNode (instance ).getEndpointManager ();
165- int activeConnectionCount = endpointManager .getActiveConnections ().size ();
166- throw new AssertionError (String .format ("Cluster size is not correct. Expected: %d Actual: %d %s" ,
162+ throw new AssertionError (String .format ("Cluster size is not correct. Expected: %d Actual: %d" ,
167163 expectedSize ,
168- clusterSize ,
169- "ActiveConnectionCount: " + activeConnectionCount ));
164+ clusterSize ));
170165 }
171166 }
172167
You can’t perform that action at this time.
0 commit comments