1212// limitations under the License.
1313package nats .io ;
1414
15- import nl .jqno .equalsverifier .EqualsVerifier ;
1615import org .junit .jupiter .api .Test ;
1716
18- import java .util .ArrayList ;
1917import java .util .Collections ;
2018import java .util .List ;
2119
22- import static nats .io .NatsRunnerUtils .DEFAULT_CLUSTER_NAME ;
23- import static nats .io .NatsRunnerUtils .createClusterInserts ;
20+ import static nats .io .NatsRunnerUtils .*;
2421import static org .junit .jupiter .api .Assertions .assertTrue ;
2522
2623public class NatsClusterTest extends TestBase {
@@ -29,24 +26,17 @@ public class NatsClusterTest extends TestBase {
2926 public void testCreateCluster () throws Exception {
3027 _testCreateCluster (createClusterInserts ());
3128 _testCreateCluster (createClusterInserts (3 ));
32- List < ClusterInsert > clusterInserts = createClusterInserts ( 3 );
29+ }
3330
34- List <ClusterNode > nodes = new ArrayList <>();
31+ private void _testCreateCluster ( List <ClusterInsert > clusterInserts ) throws Exception {
3532 for (ClusterInsert ci : clusterInserts ) {
36- nodes .add (new ClusterNode (ci .node .clusterName , ci .node .serverName , ci .node .port , ci .node .listen ));
33+ String s = ci .toString ();
34+ assertTrue (s .contains ("port:" + ci .node .port ));
35+ assertTrue (s .contains ("server_name=" + DEFAULT_SERVER_NAME_PREFIX ));
36+ assertTrue (s .contains ("listen: " + DEFAULT_HOST + ":" + ci .node .listen ));
37+ assertTrue (s .contains ("name: " + DEFAULT_CLUSTER_NAME ));
3738 }
38- _testCreateCluster (NatsRunnerUtils .createClusterInserts (nodes ));
39-
40- EqualsVerifier .simple ().forClass (ClusterInsert .class ).verify ();
4139
42- ClusterInsert ci = clusterInserts .get (0 );
43- String s = ci .toString ();
44- assertTrue (s .contains ("port:" + ci .node .port ));
45- assertTrue (s .contains ("listen:" + ci .node .host + ":" + ci .node .listen ));
46- assertTrue (s .contains ("name: " + DEFAULT_CLUSTER_NAME ));
47- }
48-
49- private void _testCreateCluster (List <ClusterInsert > clusterInserts ) throws Exception {
5040 ClusterInsert ci0 = clusterInserts .get (0 );
5141 ClusterInsert ci1 = clusterInserts .get (1 );
5242 ClusterInsert ci2 = clusterInserts .get (2 );
0 commit comments