Package org.elasticsearch.transport.nio.channel

Class TcpWriteContext

java.lang.Object

org.elasticsearch.transport.nio.channel.TcpWriteContext

All Implemented Interfaces:

WriteContext

public class TcpWriteContext
extends java.lang.Object
implements WriteContext

Constructor Summary

Constructors

Constructor	Description
TcpWriteContext(NioSocketChannel channel)

Method Summary

Modifier and Type	Method	Description
void	clearQueuedWriteOps(java.lang.Exception e)
void	flushChannel()
boolean	hasQueuedWriteOps()
void	queueWriteOperations(WriteOperation writeOperation)
void	sendMessage(BytesReference reference, ActionListener<java.lang.Void> listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpWriteContext

public TcpWriteContext(NioSocketChannel channel)

Method Detail

sendMessage

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

Specified by:

sendMessage in interface WriteContext

queueWriteOperations

public void queueWriteOperations(WriteOperation writeOperation)

Specified by:

queueWriteOperations in interface WriteContext

flushChannel

public void flushChannel()
                  throws java.io.IOException

Specified by:

flushChannel in interface WriteContext

Throws:

java.io.IOException

hasQueuedWriteOps

public boolean hasQueuedWriteOps()

Specified by:

hasQueuedWriteOps in interface WriteContext

clearQueuedWriteOps

public void clearQueuedWriteOps(java.lang.Exception e)

Specified by:

clearQueuedWriteOps in interface WriteContext