Package akka.remote.artery

Class SharedTestState

java.lang.Object

akka.remote.artery.SharedTestState

public class SharedTestState
extends java.lang.Object

Enable blackholing between given address in given direction

Constructor Summary

Constructors

Constructor	Description
SharedTestState()

Method Summary

Modifier and Type	Method	Description
void	blackhole(Address a, Address b, ThrottlerTransportAdapter.Direction direction)	Enable blackholing between given address in given direction
void	failInboundStreamOnce(java.lang.Throwable ex)	Cause the inbound stream to fail with the given exception.
scala.Option<java.lang.Throwable>	getInboundFailureOnce()	Get the exception to fail the inbound stream with and immediately reset the state to not-failed.
boolean	isBlackhole(Address from, Address to)
void	passThrough(Address a, Address b, ThrottlerTransportAdapter.Direction direction)

Methods inherited from class java.lang.Object

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

Constructor Detail

SharedTestState

public SharedTestState()

Method Detail

blackhole

public void blackhole(Address a,
                      Address b,
                      ThrottlerTransportAdapter.Direction direction)

Enable blackholing between given address in given direction

failInboundStreamOnce

public final void failInboundStreamOnce(java.lang.Throwable ex)

Cause the inbound stream to fail with the given exception. Can be used to test inbound stream restart / recovery.

Parameters:

ex - (undocumented)

getInboundFailureOnce

public final scala.Option<java.lang.Throwable> getInboundFailureOnce()

Get the exception to fail the inbound stream with and immediately reset the state to not-failed. This is used to simulate a single failure on the stream, where a successful restart recovers operations.

Returns:

(undocumented)

isBlackhole

public boolean isBlackhole(Address from,
                           Address to)

passThrough

public void passThrough(Address a,
                        Address b,
                        ThrottlerTransportAdapter.Direction direction)