Package org.elasticsearch.transport.nio.channel

Class TcpChannelFactory

java.lang.Object

org.elasticsearch.transport.nio.channel.ChannelFactory<TcpNioServerSocketChannel,TcpNioSocketChannel>

org.elasticsearch.transport.nio.channel.TcpChannelFactory

public class TcpChannelFactory
extends ChannelFactory<TcpNioServerSocketChannel,TcpNioSocketChannel>

This is an implementation of ChannelFactory which returns channels that adhere to the TcpChannel interface. The channels will use the provided TcpTransport.ProfileSettings. The provided context setters will be called with the channel after construction.

Constructor Summary

Constructors

Constructor	Description
TcpChannelFactory(TcpTransport.ProfileSettings profileSettings, java.util.function.Consumer<NioSocketChannel> contextSetter, java.util.function.Consumer<NioServerSocketChannel> serverContextSetter)

Method Summary

Modifier and Type	Method	Description
TcpNioSocketChannel	createChannel(SocketSelector selector, java.nio.channels.SocketChannel channel)	This method should return a new NioSocketChannel implementation.
TcpNioServerSocketChannel	createServerChannel(AcceptingSelector selector, java.nio.channels.ServerSocketChannel channel)	This method should return a new NioServerSocketChannel implementation.

Methods inherited from class org.elasticsearch.transport.nio.channel.ChannelFactory

acceptNioChannel, openNioChannel, openNioServerSocketChannel

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TcpChannelFactory

public TcpChannelFactory(TcpTransport.ProfileSettings profileSettings,
                         java.util.function.Consumer<NioSocketChannel> contextSetter,
                         java.util.function.Consumer<NioServerSocketChannel> serverContextSetter)

Method Detail

createChannel

public TcpNioSocketChannel createChannel(SocketSelector selector,
                                         java.nio.channels.SocketChannel channel)
                                  throws java.io.IOException

Description copied from class: ChannelFactory

This method should return a new NioSocketChannel implementation. When this method has returned, the channel should be fully created and setup. Read and write contexts and the channel exception handler should have been set.

Specified by:

createChannel in class ChannelFactory<TcpNioServerSocketChannel,TcpNioSocketChannel>

Parameters:

selector - the channel will be registered with

channel - the raw channel

Returns:

the channel

Throws:

java.io.IOException - related to the creation of the channel

createServerChannel

public TcpNioServerSocketChannel createServerChannel(AcceptingSelector selector,
                                                     java.nio.channels.ServerSocketChannel channel)
                                              throws java.io.IOException

Description copied from class: ChannelFactory

This method should return a new NioServerSocketChannel implementation. When this method has returned, the channel should be fully created and setup.

Specified by:

createServerChannel in class ChannelFactory<TcpNioServerSocketChannel,TcpNioSocketChannel>

Parameters:

selector - the channel will be registered with

channel - the raw channel

Returns:

the server channel

Throws:

java.io.IOException - related to the creation of the channel