23
23
import io .netty .channel .group .ChannelGroup ;
24
24
import io .netty .channel .group .DefaultChannelGroup ;
25
25
import io .netty .channel .pool .ChannelPoolHandler ;
26
- import io .netty .util .concurrent .EventExecutorGroup ;
26
+ import io .netty .util .concurrent .EventExecutor ;
27
27
28
28
import java .util .Map ;
29
29
import java .util .concurrent .ConcurrentHashMap ;
@@ -47,9 +47,9 @@ public class NettyChannelTracker implements ChannelPoolHandler
47
47
private final ChannelFutureListener closeListener = future -> channelClosed ( future .channel () );
48
48
private final ChannelGroup allChannels ;
49
49
50
- public NettyChannelTracker ( MetricsListener metricsListener , EventExecutorGroup eventExecutorGroup , Logging logging )
50
+ public NettyChannelTracker ( MetricsListener metricsListener , EventExecutor eventExecutor , Logging logging )
51
51
{
52
- this ( metricsListener , new DefaultChannelGroup ( "all-connections" , eventExecutorGroup . next () ), logging );
52
+ this ( metricsListener , new DefaultChannelGroup ( "all-connections" , eventExecutor ), logging );
53
53
}
54
54
55
55
public NettyChannelTracker ( MetricsListener metricsListener , ChannelGroup channels , Logging logging )
@@ -134,8 +134,8 @@ public void prepareToCloseChannels()
134
134
catch ( Throwable e )
135
135
{
136
136
// only logging it
137
- log .debug ( "Failed to destruct Channel %s due to error %s. " +
138
- "It is safe to ignore this error as the channel will be closed despite if it is successfully destructed ." , channel , e .getMessage () );
137
+ log .debug ( "Failed to prepare to close Channel %s due to error %s. " +
138
+ "It is safe to ignore this error as the channel will be closed despite if it is successfully prepared to close or not ." , channel , e .getMessage () );
139
139
}
140
140
}
141
141
}
0 commit comments