public class TransportService extends AbstractLifecycleComponent<TransportService>
Modifier and Type | Class and Description |
---|---|
protected class |
TransportService.Adapter |
Modifier and Type | Field and Description |
---|---|
static String |
SETTING_TRACE_LOG_EXCLUDE |
static String |
SETTING_TRACE_LOG_INCLUDE |
protected ThreadPool |
threadPool |
protected Transport |
transport |
lifecycle
componentSettings, logger, settings
Constructor and Description |
---|
TransportService(Settings settings,
Transport transport,
ThreadPool threadPool) |
TransportService(Transport transport,
ThreadPool threadPool) |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
nodeName
protected final Transport transport
protected final ThreadPool threadPool
public static final String SETTING_TRACE_LOG_INCLUDE
public static final String SETTING_TRACE_LOG_EXCLUDE
public TransportService(Transport transport, ThreadPool threadPool)
@Inject public TransportService(Settings settings, Transport transport, ThreadPool threadPool)
protected TransportService.Adapter createAdapter()
@Inject(optional=true) public void setDynamicSettings(NodeSettingsService nodeSettingsService, @ClusterDynamicSettings DynamicSettings dynamicSettings)
public void applySettings(Settings settings)
protected void doStart() throws ElasticsearchException
doStart
in class AbstractLifecycleComponent<TransportService>
ElasticsearchException
protected void doStop() throws ElasticsearchException
doStop
in class AbstractLifecycleComponent<TransportService>
ElasticsearchException
protected void doClose() throws ElasticsearchException
doClose
in class AbstractLifecycleComponent<TransportService>
ElasticsearchException
public boolean addressSupported(Class<? extends TransportAddress> address)
public TransportInfo info()
public TransportStats stats()
public BoundTransportAddress boundAddress()
public boolean nodeConnected(DiscoveryNode node)
public void connectToNode(DiscoveryNode node) throws ConnectTransportException
ConnectTransportException
public void connectToNodeLight(DiscoveryNode node) throws ConnectTransportException
ConnectTransportException
public void disconnectFromNode(DiscoveryNode node)
public void addConnectionListener(TransportConnectionListener listener)
public void removeConnectionListener(TransportConnectionListener listener)
public <T extends TransportResponse> TransportFuture<T> submitRequest(DiscoveryNode node, String action, TransportRequest request, TransportResponseHandler<T> handler) throws TransportException
TransportException
public <T extends TransportResponse> TransportFuture<T> submitRequest(DiscoveryNode node, String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler) throws TransportException
TransportException
public <T extends TransportResponse> void sendRequest(DiscoveryNode node, String action, TransportRequest request, TransportResponseHandler<T> handler)
public <T extends TransportResponse> void sendRequest(DiscoveryNode node, String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler)
public TransportAddress[] addressesFromString(String address) throws Exception
Exception
public void registerHandler(String action, TransportRequestHandler handler)
public void removeHandler(String action)
protected TransportRequestHandler getHandler(String action)
Copyright © 2009–2015. All rights reserved.