org.xbib.elasticsearch.transport.netty

Class NettyTransportChannel

java.lang.Object

org.xbib.elasticsearch.transport.netty.NettyTransportChannel

All Implemented Interfaces:

org.elasticsearch.transport.TransportChannel

public class NettyTransportChannel
extends Object
implements org.elasticsearch.transport.TransportChannel

Constructor Summary

Constructors

Constructor and Description
NettyTransportChannel(NettyTransport transport, String action, org.jboss.netty.channel.Channel channel, long requestId, org.elasticsearch.Version version)

Method Summary

Methods

Modifier and Type	Method and Description
String	action()
void	sendResponse(Throwable error)
void	sendResponse(org.elasticsearch.transport.TransportResponse response)
void	sendResponse(org.elasticsearch.transport.TransportResponse response, org.elasticsearch.transport.TransportResponseOptions options)

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyTransportChannel

public NettyTransportChannel(NettyTransport transport,
                     String action,
                     org.jboss.netty.channel.Channel channel,
                     long requestId,
                     org.elasticsearch.Version version)

Method Detail

action

public String action()

Specified by:

action in interface org.elasticsearch.transport.TransportChannel

sendResponse

public void sendResponse(org.elasticsearch.transport.TransportResponse response)
                  throws IOException

Specified by:

sendResponse in interface org.elasticsearch.transport.TransportChannel

Throws:

IOException

sendResponse

public void sendResponse(org.elasticsearch.transport.TransportResponse response,
                org.elasticsearch.transport.TransportResponseOptions options)
                  throws IOException

Specified by:

sendResponse in interface org.elasticsearch.transport.TransportChannel

Throws:

IOException

sendResponse

public void sendResponse(Throwable error)
                  throws IOException

Specified by:

sendResponse in interface org.elasticsearch.transport.TransportChannel

Throws:

IOException