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)