Package org.elasticsearch.transport.nio.channel

Class ChannelFactory<ServerSocket extends NioServerSocketChannel,Socket extends NioSocketChannel>

java.lang.Object

org.elasticsearch.transport.nio.channel.ChannelFactory<ServerSocket,Socket>

Direct Known Subclasses:

TcpChannelFactory

public abstract class ChannelFactory<ServerSocket extends NioServerSocketChannel,Socket extends NioSocketChannel>
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
Socket	acceptNioChannel(NioServerSocketChannel serverChannel, SocketSelector selector)
abstract Socket	createChannel(SocketSelector selector, java.nio.channels.SocketChannel channel)	This method should return a new NioSocketChannel implementation.
abstract ServerSocket	createServerChannel(AcceptingSelector selector, java.nio.channels.ServerSocketChannel channel)	This method should return a new NioServerSocketChannel implementation.
Socket	openNioChannel(java.net.InetSocketAddress remoteAddress, SocketSelector selector)
ServerSocket	openNioServerSocketChannel(java.net.InetSocketAddress address, AcceptingSelector selector)

Methods inherited from class java.lang.Object

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

Method Detail

openNioChannel

public Socket openNioChannel(java.net.InetSocketAddress remoteAddress,
                             SocketSelector selector)
                      throws java.io.IOException

Throws:

java.io.IOException

acceptNioChannel

public Socket acceptNioChannel(NioServerSocketChannel serverChannel,
                               SocketSelector selector)
                        throws java.io.IOException

Throws:

java.io.IOException

openNioServerSocketChannel

public ServerSocket openNioServerSocketChannel(java.net.InetSocketAddress address,
                                               AcceptingSelector selector)
                                        throws java.io.IOException

Throws:

java.io.IOException

createChannel

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

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.

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 abstract ServerSocket createServerChannel(AcceptingSelector selector,
                                                 java.nio.channels.ServerSocketChannel channel)
                                          throws java.io.IOException

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

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