We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ac8fab3 commit 979526bCopy full SHA for 979526b
src/test/java/com/rabbitmq/stream/impl/StreamEnvironmentTest.java
@@ -408,12 +408,12 @@ void shouldHaveSeveralLocatorsWhenSeveralUrisSpecifiedAndShouldRecoverThemIfClos
408
() ->
409
Cli.listConnections().stream()
410
.map(ConnectionInfo::clientProvidedName)
411
- .filter(name -> name.contains("-locator-"))
+ .filter(name -> name != null && name.contains("-locator-"))
412
.collect(toList());
413
List<String> locatorConnectionNames = locatorConnectionNamesSupplier.get();
414
assertThat(locatorConnectionNames).hasSameSizeAs(uris);
415
416
- locatorConnectionNames.forEach(connectionName -> Cli.killConnection(connectionName));
+ locatorConnectionNames.forEach(Cli::killConnection);
417
418
environment.streamCreator().stream(s).create();
419
try {
0 commit comments