Package org.elasticsearch.test.transport

Class FakeTransport

java.lang.Object

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.test.transport.FakeTransport

All Implemented Interfaces:

Closeable, AutoCloseable, LifecycleComponent, Releasable, Transport

public class FakeTransport
extends AbstractLifecycleComponent
implements Transport

A transport that does nothing. Normally wrapped by StubbableTransport.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.transport.Transport

Transport.Connection, Transport.RequestHandlers, Transport.ResponseContext<T extends TransportResponse>, Transport.ResponseHandlers

Field Summary

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

lifecycle

Constructor Summary

Constructors

Constructor	Description
FakeTransport()

Method Summary

Modifier and Type	Method	Description
TransportAddress[]	addressesFromString(String address)
BoundTransportAddress	boundAddress()
BoundTransportAddress	boundRemoteIngressAddress()
protected void	doClose()
protected void	doStart()
protected void	doStop()
List<String>	getDefaultSeedAddresses()
Transport.RequestHandlers	getRequestHandlers()
Transport.ResponseHandlers	getResponseHandlers()
TransportStats	getStats()
RecyclerBytesStreamOutput	newNetworkBytesStream(CircuitBreaker circuitBreaker)
void	openConnection(DiscoveryNode node, ConnectionProfile profile, ActionListener<Transport.Connection> actionListener)
Map<String,BoundTransportAddress>	profileBoundAddresses()
void	setMessageListener(TransportMessageListener messageListener)

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

addLifecycleListener, close, lifecycleState, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.common.component.LifecycleComponent

addLifecycleListener, lifecycleState, start, stop

Methods inherited from interface org.elasticsearch.core.Releasable

close

Methods inherited from interface org.elasticsearch.transport.Transport

isSecure, registerRequestHandler, setSlowLogThreshold

Constructor Details

FakeTransport

public FakeTransport()

Method Details

setMessageListener

public void setMessageListener(TransportMessageListener messageListener)

Specified by:

setMessageListener in interface Transport

boundAddress

public BoundTransportAddress boundAddress()

Specified by:

boundAddress in interface Transport

boundRemoteIngressAddress

public BoundTransportAddress boundRemoteIngressAddress()

Specified by:

boundRemoteIngressAddress in interface Transport

profileBoundAddresses

public Map<String,BoundTransportAddress> profileBoundAddresses()

Specified by:

profileBoundAddresses in interface Transport

addressesFromString

public TransportAddress[] addressesFromString(String address)

Specified by:

addressesFromString in interface Transport

getDefaultSeedAddresses

public List<String> getDefaultSeedAddresses()

Specified by:

getDefaultSeedAddresses in interface Transport

openConnection

public void openConnection(DiscoveryNode node,
 ConnectionProfile profile,
 ActionListener<Transport.Connection> actionListener)

Specified by:

openConnection in interface Transport

getStats

public TransportStats getStats()

Specified by:

getStats in interface Transport

getResponseHandlers

public Transport.ResponseHandlers getResponseHandlers()

Specified by:

getResponseHandlers in interface Transport

getRequestHandlers

public Transport.RequestHandlers getRequestHandlers()

Specified by:

getRequestHandlers in interface Transport

newNetworkBytesStream

public RecyclerBytesStreamOutput newNetworkBytesStream(@Nullable
 CircuitBreaker circuitBreaker)

Specified by:

newNetworkBytesStream in interface Transport

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()

Specified by:

doClose in class AbstractLifecycleComponent