com.neeve.sma.impl.loopback
Class LoopbackBus.AgentTestController

java.lang.Object
  com.neeve.sma.impl.loopback.LoopbackBus.AgentTestController

Enclosing class:

LoopbackBus

public final class LoopbackBus.AgentTestController
extends Object

Implements an agent's test controller.

Method Summary

boolean	dropNextAck() Get if configured to drop the next ack dispatched by the bus
LoopbackBus.AgentTestController	dropNextAck(boolean val) Drop the next ack dispatched by the bus
boolean	dupNextAck() Get if configured to dup the next ack dispatched by the bus
LoopbackBus.AgentTestController	dupNextAck(boolean val) Dup the next ack dispatched by the bus
boolean	failAllConnects() Returns if the all connects are set to be failed.
LoopbackBus.AgentTestController	failAllConnects(boolean val, boolean permanent) Set whether the all subsequent agent connect should be intentionally failed.
boolean	failAllConnectsPermanent() Returns if the all connect is set to be failed permanently.
LoopbackBus.AgentTestController	failConnection() Fail the agent's connection to the bus
boolean	failNextConnect() Returns if the next connect is set to be failed.
LoopbackBus.AgentTestController	failNextConnect(boolean val, boolean permanent) Set whether the next agent connect should be intentionally failed.
boolean	failNextConnectPermanent() Returns if the next connect is set to be failed permanently.
boolean	failNextPublish() Returns if the next publish is set to be failed.
LoopbackBus.AgentTestController	failNextPublish(boolean val) Set whether the next publish should be intentionally failed.
boolean	failNextPublishWithException() Returns if the next publish is set to be failed with exception.
LoopbackBus.AgentTestController	failNextPublishWithException(boolean val) Set whether the next publish should be intentionally failed with an exception.
boolean	failNextStart() Returns whether the next agent start will be intentionally failed.
LoopbackBus.AgentTestController	failNextStart(boolean val) Set whether the agent start should be intentionally failed.
String	getAgentName() Get the name of the agent being controlled by this object
boolean	isCongested() Get if traffic is congested
int	oooAckGap() Get the out of order ack remaining gap size
LoopbackBus.AgentTestController	oooAckGap(int val) Set the out of order ack gap
LoopbackBus.AgentTestController	setCongested(boolean val) Start random traffic congestion

Methods inherited from class java.lang.Object

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

Method Detail

getAgentName

public final String getAgentName()

Get the name of the agent being controlled by this object

failNextConnect

public final LoopbackBus.AgentTestController failNextConnect(boolean val,
                                                             boolean permanent)

Set whether the next agent connect should be intentionally failed.

failNextConnect

public final boolean failNextConnect()

Returns if the next connect is set to be failed.

failNextConnectPermanent

public final boolean failNextConnectPermanent()

Returns if the next connect is set to be failed permanently.

failAllConnects

public final LoopbackBus.AgentTestController failAllConnects(boolean val,
                                                             boolean permanent)

Set whether the all subsequent agent connect should be intentionally failed.

failAllConnects

public final boolean failAllConnects()

Returns if the all connects are set to be failed.

failAllConnectsPermanent

public final boolean failAllConnectsPermanent()

Returns if the all connect is set to be failed permanently.

failNextStart

public final LoopbackBus.AgentTestController failNextStart(boolean val)

Set whether the agent start should be intentionally failed.

failNextStart

public final boolean failNextStart()

Returns whether the next agent start will be intentionally failed.

failNextPublish

public final LoopbackBus.AgentTestController failNextPublish(boolean val)

Set whether the next publish should be intentionally failed.

failNextPublishWithException

public final LoopbackBus.AgentTestController failNextPublishWithException(boolean val)

Set whether the next publish should be intentionally failed with an exception.

failNextPublish

public final boolean failNextPublish()

Returns if the next publish is set to be failed.

failNextPublishWithException

public final boolean failNextPublishWithException()

Returns if the next publish is set to be failed with exception.

failConnection

public final LoopbackBus.AgentTestController failConnection()
                                                     throws SmaException

Fail the agent's connection to the bus

Throws:

SmaException

setCongested

public final LoopbackBus.AgentTestController setCongested(boolean val)

Start random traffic congestion

isCongested

public final boolean isCongested()

Get if traffic is congested

dropNextAck

public final LoopbackBus.AgentTestController dropNextAck(boolean val)

Drop the next ack dispatched by the bus

dropNextAck

public final boolean dropNextAck()

Get if configured to drop the next ack dispatched by the bus

dupNextAck

public final LoopbackBus.AgentTestController dupNextAck(boolean val)

Dup the next ack dispatched by the bus

dupNextAck

public final boolean dupNextAck()

Get if configured to dup the next ack dispatched by the bus

oooAckGap

public final LoopbackBus.AgentTestController oooAckGap(int val)

Set the out of order ack gap

oooAckGap

public final int oooAckGap()

Get the out of order ack remaining gap size