org.elasticsearch.transport
Class TransportService

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.common.component.AbstractLifecycleComponent<TransportService>
          org.elasticsearch.transport.TransportService

All Implemented Interfaces:

CloseableComponent, LifecycleComponent<TransportService>

public class TransportService
extends AbstractLifecycleComponent<TransportService>

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

TransportService(Settings settings, Transport transport, ThreadPool threadPool)

TransportService(Transport transport, ThreadPool threadPool)

Method Summary

void	addConnectionListener(TransportConnectionListener listener)
TransportAddress[]	addressesFromString(String address)
boolean	addressSupported(Class<? extends TransportAddress> address)
BoundTransportAddress	boundAddress()
void	connectToNode(DiscoveryNode node)
void	connectToNodeLight(DiscoveryNode node)
void	disconnectFromNode(DiscoveryNode node)
protected void	doClose()
protected void	doStart()
protected void	doStop()
TransportInfo	info()
boolean	nodeConnected(DiscoveryNode node)
void	registerHandler(ActionTransportRequestHandler handler)
void	registerHandler(String action, TransportRequestHandler handler)
void	removeConnectionListener(TransportConnectionListener listener)
void	removeHandler(String action)
<T extends Streamable> void	sendRequest(DiscoveryNode node, String action, Streamable message, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends Streamable> void	sendRequest(DiscoveryNode node, String action, Streamable message, TransportResponseHandler<T> handler)
TransportStats	stats()
<T extends Streamable> TransportFuture<T>	submitRequest(DiscoveryNode node, String action, Streamable message, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends Streamable> TransportFuture<T>	submitRequest(DiscoveryNode node, String action, Streamable message, TransportResponseHandler<T> handler)
void	throwConnectException(boolean throwConnectException) Set to true to indicate that a ConnectTransportException should be thrown when sending a message (otherwise, it will be passed to the response handler).

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportService

public TransportService(Transport transport,
                        ThreadPool threadPool)

TransportService

@Inject
public TransportService(Settings settings,
                               Transport transport,
                               ThreadPool threadPool)

Method Detail

doStart

protected void doStart()
                throws ElasticSearchException

Specified by:

doStart in class AbstractLifecycleComponent<TransportService>

Throws:

ElasticSearchException

doStop

protected void doStop()
               throws ElasticSearchException

Specified by:

doStop in class AbstractLifecycleComponent<TransportService>

Throws:

ElasticSearchException

doClose

protected void doClose()
                throws ElasticSearchException

Specified by:

doClose in class AbstractLifecycleComponent<TransportService>

Throws:

ElasticSearchException

addressSupported

public boolean addressSupported(Class<? extends TransportAddress> address)

info

public TransportInfo info()

stats

public TransportStats stats()

boundAddress

public BoundTransportAddress boundAddress()

nodeConnected

public boolean nodeConnected(DiscoveryNode node)

connectToNode

public void connectToNode(DiscoveryNode node)
                   throws ConnectTransportException

Throws:

ConnectTransportException

connectToNodeLight

public void connectToNodeLight(DiscoveryNode node)
                        throws ConnectTransportException

Throws:

ConnectTransportException

disconnectFromNode

public void disconnectFromNode(DiscoveryNode node)

addConnectionListener

public void addConnectionListener(TransportConnectionListener listener)

removeConnectionListener

public void removeConnectionListener(TransportConnectionListener listener)

throwConnectException

public void throwConnectException(boolean throwConnectException)

Set to true to indicate that a ConnectTransportException should be thrown when sending a message (otherwise, it will be passed to the response handler). Defaults to false.

This is useful when logic based on connect failure is needed without having to wrap the handler, for example, in case of retries across several nodes.

submitRequest

public <T extends Streamable> TransportFuture<T> submitRequest(DiscoveryNode node,
                                                               String action,
                                                               Streamable message,
                                                               TransportResponseHandler<T> handler)
                                                    throws TransportException

Throws:

TransportException

submitRequest

public <T extends Streamable> TransportFuture<T> submitRequest(DiscoveryNode node,
                                                               String action,
                                                               Streamable message,
                                                               TransportRequestOptions options,
                                                               TransportResponseHandler<T> handler)
                                                    throws TransportException

Throws:

TransportException

sendRequest

public <T extends Streamable> void sendRequest(DiscoveryNode node,
                                               String action,
                                               Streamable message,
                                               TransportResponseHandler<T> handler)
                 throws TransportException

Throws:

TransportException

sendRequest

public <T extends Streamable> void sendRequest(DiscoveryNode node,
                                               String action,
                                               Streamable message,
                                               TransportRequestOptions options,
                                               TransportResponseHandler<T> handler)
                 throws TransportException

Throws:

TransportException

addressesFromString

public TransportAddress[] addressesFromString(String address)
                                       throws Exception

Throws:

Exception

registerHandler

public void registerHandler(ActionTransportRequestHandler handler)

registerHandler

public void registerHandler(String action,
                            TransportRequestHandler handler)

removeHandler

public void removeHandler(String action)