@@ -322,7 +322,8 @@ protected static String format(ThreadLocal<NumberFormat> formatter, Number value
322322 telemetryClientChannel = clientChannel ;
323323 telemetryStatsDProcessor = statsDProcessor ;
324324 } else {
325- telemetryClientChannel = createByteChannel (telemetryAddressLookup , timeout , connectionTimeout , bufferSize , enableJdkSocket );
325+ telemetryClientChannel = createByteChannel (telemetryAddressLookup , timeout , connectionTimeout ,
326+ bufferSize , enableJdkSocket );
326327
327328 // similar settings, but a single worker and non-blocking.
328329 telemetryStatsDProcessor = createProcessor (queueSize , handler , getPacketSize (telemetryClientChannel ),
@@ -499,7 +500,8 @@ ClientChannel createByteChannel(
499500 // Allow us to support `unix://` for both kind of sockets like in go.
500501 switch (unixAddr .getTransportType ()) {
501502 case UDS_STREAM :
502- return new UnixStreamClientChannel (unixAddr .getAddress (), timeout , connectionTimeout , bufferSize , enableJdkSocket );
503+ return new UnixStreamClientChannel (unixAddr .getAddress (), timeout , connectionTimeout ,
504+ bufferSize , enableJdkSocket );
503505 case UDS_DATAGRAM :
504506 case UDS :
505507 return new UnixDatagramClientChannel (unixAddr .getAddress (), timeout , bufferSize );
0 commit comments