Package org.apache.nemo.runtime.common

Interface NettyChannelImplementationSelector

All Known Implementing Classes:

NativeChannelImplementationSelector, NioChannelImplementationSelector

@DefaultImplementation(NativeChannelImplementationSelector.class)
public interface NettyChannelImplementationSelector

Selects appropriate Channel implementation.

Method Summary

Modifier and Type	Method	Description
java.lang.Class<? extends io.netty.channel.Channel>	getChannelClass()
java.lang.Class<? extends io.netty.channel.ServerChannel>	getServerChannelClass()
io.netty.channel.EventLoopGroup	newEventLoopGroup(int numThreads, java.util.concurrent.ThreadFactory threadFactory)	Creates a new EventLoopGroup.

Method Detail

newEventLoopGroup

io.netty.channel.EventLoopGroup newEventLoopGroup(int numThreads,
                                                  java.util.concurrent.ThreadFactory threadFactory)

Creates a new EventLoopGroup.

Parameters:

numThreads - the number of threads

threadFactory - the ThreadFactory

Returns:

a new EventLoopGroup

getServerChannelClass

java.lang.Class<? extends io.netty.channel.ServerChannel> getServerChannelClass()

Returns:

class for server channel

getChannelClass

java.lang.Class<? extends io.netty.channel.Channel> getChannelClass()

Returns:

class for channel