Update versions

Fix tests
This commit is contained in:
Soby Chacko
2020-06-03 13:27:22 -04:00
parent 205f1f9338
commit 2b1a75b413

View File

@@ -183,7 +183,7 @@ public class HttpRequestFunctionApplicationTests {
runner.run(context -> {
HttpRequestFunction httpRequestFunction = context.getBean(HttpRequestFunction.class);
StepVerifier.create(httpRequestFunction.apply(Flux.just(new GenericMessage(""))))
.expectErrorMatches(throwable -> throwable.getMessage().startsWith("Connection refused"))
.expectErrorMatches(throwable -> throwable.getMessage().contains("Connection refused"))
.verify();
});
}