@@ -480,11 +480,11 @@ public void call() {
480480 };
481481 }
482482
483- public void drainChannelAndOffer (final Channel channel ,final NettyResponseFuture <?>future ) {
483+ public void drainChannelAndOffer (Channel channel ,NettyResponseFuture <?>future ) {
484484drainChannelAndOffer (channel ,future ,future .isKeepAlive (),future .getPartitionKey ());
485485 }
486486
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 ) {
488488Channels .setAttribute (channel ,newDrainCallback (future ,channel ,keepAlive ,partitionKey ));
489489 }
490490
@@ -497,15 +497,15 @@ public EventLoopGroup getEventLoopGroup() {
497497 }
498498
499499public ClientStats getClientStats () {
500- final Map <String ,Long >totalConnectionsPerHost =openChannels
500+ Map <String ,Long >totalConnectionsPerHost =openChannels
501501 .stream ()
502502 .map (Channel ::remoteAddress )
503503 .filter (a ->a .getClass () ==InetSocketAddress .class )
504504 .map (a -> (InetSocketAddress )a )
505505 .map (InetSocketAddress ::getHostName )
506506 .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
509509 .entrySet ()
510510 .stream ()
511511 .collect (Collectors .toMap (