File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
modules/transport-netty4/src/test/java/org/opensearch/http/netty4 Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change 3232
3333package org .opensearch .http .netty4 ;
3434
35+ import org .apache .logging .log4j .LogManager ;
36+ import org .apache .logging .log4j .Logger ;
3537import org .opensearch .common .TriFunction ;
3638import org .opensearch .common .collect .Tuple ;
3739import org .opensearch .common .settings .Settings ;
117119 * Tiny helper to send http requests over netty.
118120 */
119121public class Netty4HttpClient implements Closeable {
120-
122+ private static final Logger logger = LogManager .getLogger (Netty4HttpClient .class );
123+
121124 static Collection <String > returnHttpResponseBodies (Collection <FullHttpResponse > responses ) {
122125 List <String > list = new ArrayList <>(responses .size ());
123126 for (FullHttpResponse response : responses ) {
@@ -518,6 +521,8 @@ protected void initChannel(DatagramChannel ch) {
518521
519522 @ Override
520523 Channel prepare (Bootstrap clientBootstrap , Channel channel ) throws InterruptedException {
524+ logger .info ("Connecting to: " + channel .remoteAddress ());
525+
521526 final QuicChannel quicChannel = QuicChannel .newBootstrap (channel )
522527 .option (ChannelOption .CONNECT_TIMEOUT_MILLIS , 30000 ) // 30 seconds
523528 .handler (new Http3ClientConnectionHandler ())
You can’t perform that action at this time.
0 commit comments