import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
-import io.netty.channel.socket.nio.NioDatagramChannel;
+import io.netty.channel.socket.DatagramChannel;
import com.google.common.util.concurrent.SettableFuture;
*
* @author michal.polkorab
*/
-public class UdpSimpleClientInitializer extends ChannelInitializer<NioDatagramChannel> {
+public class UdpSimpleClientInitializer extends ChannelInitializer<DatagramChannel> {
private SettableFuture<Boolean> isOnlineFuture;
private ScenarioHandler scenarioHandler;
}
@Override
- public void initChannel(NioDatagramChannel ch) throws Exception {
+ public void initChannel(DatagramChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
SimpleClientHandler simpleClientHandler = new SimpleClientHandler(isOnlineFuture, scenarioHandler);
simpleClientHandler.setScenario(scenarioHandler);