Package org.elasticsearch.test.transport

Class MockTransportService.ClearableTransport

java.lang.Object

org.elasticsearch.test.transport.MockTransportService.DelegateTransport

org.elasticsearch.test.transport.MockTransportService.ClearableTransport

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, LifecycleComponent, Releasable, Transport

Enclosing class:

MockTransportService

public abstract static class MockTransportService.ClearableTransport
extends MockTransportService.DelegateTransport

The delegate transport instances defined in this class mock various kinds of disruption types. This subclass adds a method clearRule() so that when the disruptions are cleared (see MockTransportService.clearRule(TransportService)) this gives the disruption a possibility to run clean-up actions.

Nested Class Summary

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

Transport.Connection

Field Summary

Fields inherited from class org.elasticsearch.test.transport.MockTransportService.DelegateTransport

transport

Fields inherited from interface org.elasticsearch.transport.Transport

TRANSPORT_TCP_COMPRESS

Constructor Summary

Constructors

Constructor	Description
ClearableTransport(Transport transport)

Method Summary

Modifier and Type	Method	Description
abstract void	clearRule()	Called by MockTransportService.clearRule(TransportService)

Methods inherited from class org.elasticsearch.test.transport.MockTransportService.DelegateTransport

addLifecycleListener, addressesFromString, boundAddress, close, connectToNode, disconnectFromNode, getConnection, getLocalAddresses, getStats, lifecycleState, newRequestId, nodeConnected, openConnection, profileBoundAddresses, removeLifecycleListener, sendRequest, setTransportService, 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.transport.Transport

getInFlightRequestBreaker

Constructor Detail

ClearableTransport

public ClearableTransport(Transport transport)

Method Detail

clearRule

public abstract void clearRule()

Called by MockTransportService.clearRule(TransportService)