org.elasticsearch.transport

Class TcpTransportChannel<Channel>

java.lang.Object

org.elasticsearch.transport.TcpTransportChannel<Channel>

All Implemented Interfaces:

TransportChannel

public final class TcpTransportChannel<Channel>
extends java.lang.Object
implements TransportChannel

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	action
protected long	requestId
protected Version	version

Constructor Summary

Constructors

Constructor and Description
TcpTransportChannel(TcpTransport<Channel> transport, Channel channel, java.lang.String channelType, java.lang.String action, long requestId, Version version, java.lang.String profileName, long reservedBytes)

Method Summary

Modifier and Type	Method and Description
java.lang.String	action()
Channel	getChannel()
java.lang.String	getChannelType()
java.lang.String	getProfileName()
long	getRequestId()
Version	getVersion() Returns the version of the other party that this channel will send a response to.
void	sendResponse(java.lang.Exception exception)
void	sendResponse(TransportResponse response)
void	sendResponse(TransportResponse response, TransportResponseOptions options)

Methods inherited from class java.lang.Object

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

Field Detail

version

protected final Version version

action

protected final java.lang.String action

requestId

protected final long requestId

Constructor Detail

TcpTransportChannel

public TcpTransportChannel(TcpTransport<Channel> transport,
                           Channel channel,
                           java.lang.String channelType,
                           java.lang.String action,
                           long requestId,
                           Version version,
                           java.lang.String profileName,
                           long reservedBytes)

Method Detail

getProfileName

public java.lang.String getProfileName()

Specified by:

getProfileName in interface TransportChannel

action

public java.lang.String action()

Specified by:

action in interface TransportChannel

sendResponse

public void sendResponse(TransportResponse response)
                  throws java.io.IOException

Specified by:

sendResponse in interface TransportChannel

Throws:

java.io.IOException

sendResponse

public void sendResponse(TransportResponse response,
                         TransportResponseOptions options)
                  throws java.io.IOException

Specified by:

sendResponse in interface TransportChannel

Throws:

java.io.IOException

sendResponse

public void sendResponse(java.lang.Exception exception)
                  throws java.io.IOException

Specified by:

sendResponse in interface TransportChannel

Throws:

java.io.IOException

getRequestId

public long getRequestId()

Specified by:

getRequestId in interface TransportChannel

getChannelType

public java.lang.String getChannelType()

Specified by:

getChannelType in interface TransportChannel

getChannel

public Channel getChannel()

getVersion

public Version getVersion()

Description copied from interface: TransportChannel

Returns the version of the other party that this channel will send a response to.

Specified by:

getVersion in interface TransportChannel