Package org.elasticsearch.transport.nio.channel

Class TcpNioServerSocketChannel

java.lang.Object

org.elasticsearch.transport.nio.channel.AbstractNioChannel<java.nio.channels.ServerSocketChannel>

org.elasticsearch.transport.nio.channel.NioServerSocketChannel

org.elasticsearch.transport.nio.channel.TcpNioServerSocketChannel

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Releasable, NioChannel, TcpChannel

public class TcpNioServerSocketChannel
extends NioServerSocketChannel
implements TcpChannel

This is an implementation of NioServerSocketChannel that adheres to the TcpChannel interface. As it is a server socket, setting SO_LINGER and sending messages is not supported.

Method Summary

Modifier and Type	Method	Description
void	sendMessage(BytesReference reference, ActionListener<java.lang.Void> listener)
void	setSoLinger(int value)
java.lang.String	toString()

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

addCloseListener, close, closeFromSelector, getLocalAddress, getRawChannel, getSelectionKey, getSelector, isOpen, register

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

getAcceptContext, getChannelFactory, setAcceptContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.transport.TcpChannel

addCloseListener, close, getLocalAddress, isOpen

Method Detail

sendMessage

public void sendMessage(BytesReference reference,
                        ActionListener<java.lang.Void> listener)

Specified by:

sendMessage in interface TcpChannel

setSoLinger

public void setSoLinger(int value)
                 throws java.io.IOException

Specified by:

setSoLinger in interface TcpChannel

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class NioServerSocketChannel