Skip to content

Commit 8ab017d

Browse files
committed
1.2.5 update cluster creation utils for JS support
1 parent 65a49c1 commit 8ab017d

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

src/main/java/nats/io/NatsServerRunner.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -678,7 +678,7 @@ public NatsServerRunnerOptions buildOptions() {
678678
// ====================================================================================================
679679
// Runner Wide Setting
680680
// ====================================================================================================
681-
private static final Supplier<Output> DefaultLoggingSupplier = () -> new LoggingOutput(Logger.getLogger(NatsServerRunner.class.getName()));
681+
static final Supplier<Output> DefaultLoggingSupplier = () -> new LoggingOutput(Logger.getLogger(NatsServerRunner.class.getName()));
682682

683683
private static Supplier<Output> DefaultOutputSupplier = DefaultLoggingSupplier;
684684
private static Level DefaultOutputLevel = Level.INFO;

src/test/java/nats/io/NatsClusterTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -59,18 +59,18 @@ private void _testCreateCluster(List<ClusterInsert> clusterInserts) throws Excep
5959

6060
validateCommandLine(runner0, false, false);
6161
validateHostAndPort(runner0);
62-
validateConfigLines(runner0, Collections.singletonList("name: clstr"));
62+
validateConfigLines(runner0, Collections.singletonList("name: cluster"));
6363

6464
connect(runner0);
6565

6666
validateCommandLine(runner1, false, false);
6767
validateHostAndPort(runner1);
68-
validateConfigLines(runner1, Collections.singletonList("name: clstr"));
68+
validateConfigLines(runner1, Collections.singletonList("name: cluster"));
6969
connect(runner1);
7070

7171
validateCommandLine(runner2, false, false);
7272
validateHostAndPort(runner2);
73-
validateConfigLines(runner2, Collections.singletonList("name: clstr"));
73+
validateConfigLines(runner2, Collections.singletonList("name: cluster"));
7474
connect(runner2);
7575
}
7676
}

src/test/java/nats/io/NatsServerRunnerTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import java.util.logging.Logger;
3030
import java.util.stream.Stream;
3131

32+
import static nats.io.NatsServerRunner.DefaultLoggingSupplier;
3233
import static nats.io.NatsServerRunner.getDefaultOutputSupplier;
3334
import static org.junit.jupiter.api.Assertions.*;
3435

@@ -252,8 +253,7 @@ public void testStaticStuff() {
252253
assertEquals(supplier, getDefaultOutputSupplier());
253254

254255
NatsServerRunner.setDefaultOutputSupplier(null);
255-
assertEquals(dflt, getDefaultOutputSupplier());
256-
assertNotEquals(supplier, getDefaultOutputSupplier());
256+
assertEquals(DefaultLoggingSupplier, getDefaultOutputSupplier());
257257
}
258258

259259
@Test

0 commit comments

Comments
 (0)