org.elasticsearch.transport.local
Class LocalTransportChannel

java.lang.Object
  org.elasticsearch.transport.local.LocalTransportChannel

All Implemented Interfaces:

TransportChannel

public class LocalTransportChannel
extends Object
implements TransportChannel

Constructor Summary

LocalTransportChannel(LocalTransport sourceTransport, LocalTransport targetTransport, String action, long requestId)

Method Summary

String	action()
void	sendResponse(Streamable message)
void	sendResponse(Streamable message, TransportResponseOptions options)
void	sendResponse(Throwable error)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalTransportChannel

public LocalTransportChannel(LocalTransport sourceTransport,
                             LocalTransport targetTransport,
                             String action,
                             long requestId)

Method Detail

action

public String action()

Specified by:

action in interface TransportChannel

sendResponse

public void sendResponse(Streamable message)
                  throws IOException

Specified by:

sendResponse in interface TransportChannel

Throws:

IOException

sendResponse

public void sendResponse(Streamable message,
                         TransportResponseOptions options)
                  throws IOException

Specified by:

sendResponse in interface TransportChannel

Throws:

IOException

sendResponse

public void sendResponse(Throwable error)
                  throws IOException

Specified by:

sendResponse in interface TransportChannel

Throws:

IOException