Package org.elasticsearch.transport.nio.channel

Class NioServerSocketChannel

java.lang.Object

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

org.elasticsearch.transport.nio.channel.NioServerSocketChannel

All Implemented Interfaces:

NioChannel

Direct Known Subclasses:

TcpNioServerSocketChannel

public class NioServerSocketChannel
extends AbstractNioChannel<java.nio.channels.ServerSocketChannel>

Constructor Summary

Constructors

Constructor	Description
NioServerSocketChannel(java.nio.channels.ServerSocketChannel socketChannel, ChannelFactory channelFactory, AcceptingSelector selector)

Method Summary

Modifier and Type	Method	Description
java.util.function.Consumer<NioSocketChannel>	getAcceptContext()
ChannelFactory	getChannelFactory()
void	setAcceptContext(java.util.function.Consumer<NioSocketChannel> acceptContext)	This method sets the accept context for a server socket channel.
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 java.lang.Object

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

Constructor Detail

NioServerSocketChannel

public NioServerSocketChannel(java.nio.channels.ServerSocketChannel socketChannel,
                              ChannelFactory channelFactory,
                              AcceptingSelector selector)
                       throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getChannelFactory

public ChannelFactory getChannelFactory()

setAcceptContext

public void setAcceptContext(java.util.function.Consumer<NioSocketChannel> acceptContext)

This method sets the accept context for a server socket channel. The accept context is called when a new channel is accepted. The parameter passed to the context is the new channel.

Parameters:

acceptContext - to call

getAcceptContext

public java.util.function.Consumer<NioSocketChannel> getAcceptContext()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object