File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
src/test/java/com/rabbitmq/stream/impl Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change 2020import static org .assertj .core .api .Assertions .assertThat ;
2121import static org .assertj .core .api .Assertions .assertThatThrownBy ;
2222
23+ import com .rabbitmq .stream .Address ;
2324import com .rabbitmq .stream .ChannelCustomizer ;
2425import com .rabbitmq .stream .ConfirmationHandler ;
2526import com .rabbitmq .stream .Environment ;
@@ -277,6 +278,7 @@ void environmentPublisherConsumer() throws Exception {
277278 try (Environment env =
278279 Environment .builder ()
279280 .uri ("rabbitmq-stream+tls://localhost" )
281+ .addressResolver (addr -> new Address ("localhost" , Client .DEFAULT_TLS_PORT ))
280282 .tls ()
281283 .sslContext (SslContextBuilder .forClient ().trustManager (caCertificate ()).build ())
282284 .environmentBuilder ()
You can’t perform that action at this time.
0 commit comments