@@ -480,11 +480,11 @@ public void call() {
480
480
};
481
481
}
482
482
483
- public void drainChannelAndOffer (final Channel channel , final NettyResponseFuture <?> future ) {
483
+ public void drainChannelAndOffer (Channel channel , NettyResponseFuture <?> future ) {
484
484
drainChannelAndOffer (channel , future , future .isKeepAlive (), future .getPartitionKey ());
485
485
}
486
486
487
- public void drainChannelAndOffer (final Channel channel , final NettyResponseFuture <?> future , boolean keepAlive , Object partitionKey ) {
487
+ public void drainChannelAndOffer (Channel channel , NettyResponseFuture <?> future , boolean keepAlive , Object partitionKey ) {
488
488
Channels .setAttribute (channel , newDrainCallback (future , channel , keepAlive , partitionKey ));
489
489
}
490
490
@@ -497,15 +497,15 @@ public EventLoopGroup getEventLoopGroup() {
497
497
}
498
498
499
499
public ClientStats getClientStats () {
500
- final Map <String , Long > totalConnectionsPerHost = openChannels
500
+ Map <String , Long > totalConnectionsPerHost = openChannels
501
501
.stream ()
502
502
.map (Channel ::remoteAddress )
503
503
.filter (a -> a .getClass () == InetSocketAddress .class )
504
504
.map (a -> (InetSocketAddress ) a )
505
505
.map (InetSocketAddress ::getHostName )
506
506
.collect (Collectors .groupingBy (Function .identity (), Collectors .counting ()));
507
- final Map <String , Long > idleConnectionsPerHost = channelPool .getIdleChannelCountPerHost ();
508
- final Map <String , HostStats > statsPerHost = totalConnectionsPerHost
507
+ Map <String , Long > idleConnectionsPerHost = channelPool .getIdleChannelCountPerHost ();
508
+ Map <String , HostStats > statsPerHost = totalConnectionsPerHost
509
509
.entrySet ()
510
510
.stream ()
511
511
.collect (Collectors .toMap (
0 commit comments