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:

AutoCloseable, LifecycleComponent<TransportService>, Releasable

public class TransportService
extends AbstractLifecycleComponent<TransportService>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	TransportService.Adapter

Field Summary

Fields

Modifier and Type	Field and Description
static String	SETTING_TRACE_LOG_EXCLUDE
static String	SETTING_TRACE_LOG_INCLUDE
protected ThreadPool	threadPool
protected Transport	transport

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

lifecycle

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

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportService(Settings settings, Transport transport, ThreadPool threadPool)
TransportService(Transport transport, ThreadPool threadPool)

Method Summary

Modifier and Type	Method and Description
void	addConnectionListener(TransportConnectionListener listener)
TransportAddress[]	addressesFromString(String address)
boolean	addressSupported(Class<? extends TransportAddress> address)
void	applySettings(Settings settings)
BoundTransportAddress	boundAddress()
void	connectToNode(DiscoveryNode node)
void	connectToNodeLight(DiscoveryNode node)
protected TransportService.Adapter	createAdapter()
void	disconnectFromNode(DiscoveryNode node)
protected void	doClose()
protected void	doStart()
protected void	doStop()
protected TransportRequestHandler	getHandler(String action)
TransportInfo	info()
boolean	nodeConnected(DiscoveryNode node)
void	registerHandler(String action, TransportRequestHandler handler)
void	removeConnectionListener(TransportConnectionListener listener)
void	removeHandler(String action)
<T extends TransportResponse> void	sendRequest(DiscoveryNode node, String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendRequest(DiscoveryNode node, String action, TransportRequest request, TransportResponseHandler<T> handler)
void	setDynamicSettings(NodeSettingsService nodeSettingsService, DynamicSettings dynamicSettings)
TransportStats	stats()
<T extends TransportResponse> TransportFuture<T>	submitRequest(DiscoveryNode node, String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends TransportResponse> TransportFuture<T>	submitRequest(DiscoveryNode node, String action, TransportRequest request, TransportResponseHandler<T> 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

Field Detail

transport

protected final Transport transport

threadPool

protected final ThreadPool threadPool

SETTING_TRACE_LOG_INCLUDE

public static final String SETTING_TRACE_LOG_INCLUDE

See Also:

Constant Field Values

SETTING_TRACE_LOG_EXCLUDE

public static final String SETTING_TRACE_LOG_EXCLUDE

See Also:

Constant Field Values

Constructor Detail

TransportService

public TransportService(Transport transport,
                        ThreadPool threadPool)

TransportService

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

Method Detail

createAdapter

protected TransportService.Adapter createAdapter()

setDynamicSettings

@Inject(optional=true)
public void setDynamicSettings(NodeSettingsService nodeSettingsService,
                                                      @ClusterDynamicSettings
                                                      DynamicSettings dynamicSettings)

applySettings

public void applySettings(Settings settings)

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)

submitRequest

public <T extends TransportResponse> TransportFuture<T> submitRequest(DiscoveryNode node,
                                                                      String action,
                                                                      TransportRequest request,
                                                                      TransportResponseHandler<T> handler)
                                                               throws TransportException

Throws:

TransportException

submitRequest

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

Throws:

TransportException

sendRequest

public <T extends TransportResponse> void sendRequest(DiscoveryNode node,
                                                      String action,
                                                      TransportRequest request,
                                                      TransportResponseHandler<T> handler)

sendRequest

public <T extends TransportResponse> void sendRequest(DiscoveryNode node,
                                                      String action,
                                                      TransportRequest request,
                                                      TransportRequestOptions options,
                                                      TransportResponseHandler<T> handler)

addressesFromString

public TransportAddress[] addressesFromString(String address)
                                       throws Exception

Throws:

Exception

registerHandler

public void registerHandler(String action,
                            TransportRequestHandler handler)

removeHandler

public void removeHandler(String action)

getHandler

protected TransportRequestHandler getHandler(String action)