com.rabbitmq.perf

Class AgentBase

java.lang.Object

com.rabbitmq.perf.AgentBase

Direct Known Subclasses:

Consumer, Producer

public abstract class AgentBase
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	AgentBase.AgentState

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AgentBase(com.rabbitmq.perf.StartListener startListener)

Method Summary

Modifier and Type	Method and Description
protected void	dealWithWriteOperation(com.rabbitmq.perf.AgentBase.WriteOperation writeOperation, com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess)
protected void	handleShutdownSignalExceptionOnWrite(com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess, com.rabbitmq.client.ShutdownSignalException e)
protected boolean	isConnectionRecoveryTriggered(com.rabbitmq.client.ShutdownSignalException e)
abstract void	recover(TopologyRecording topologyRecording)
void	setTopologyRecording(TopologyRecording topologyRecording)
protected boolean	shouldStop(com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess, com.rabbitmq.client.ShutdownSignalException e)
protected void	started()
protected TopologyRecording	topologyRecording()
protected abstract StartListener.Type	type()

Methods inherited from class java.lang.Object

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

Constructor Detail

AgentBase

protected AgentBase(com.rabbitmq.perf.StartListener startListener)

Method Detail

setTopologyRecording

public void setTopologyRecording(TopologyRecording topologyRecording)

topologyRecording

protected TopologyRecording topologyRecording()

isConnectionRecoveryTriggered

protected boolean isConnectionRecoveryTriggered(com.rabbitmq.client.ShutdownSignalException e)

handleShutdownSignalExceptionOnWrite

protected void handleShutdownSignalExceptionOnWrite(com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess,
                                                    com.rabbitmq.client.ShutdownSignalException e)

shouldStop

protected boolean shouldStop(com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess,
                             com.rabbitmq.client.ShutdownSignalException e)

dealWithWriteOperation

protected void dealWithWriteOperation(com.rabbitmq.perf.AgentBase.WriteOperation writeOperation,
                                      com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess)
                               throws java.io.IOException

Throws:

java.io.IOException

started

protected void started()

type

protected abstract StartListener.Type type()

recover

public abstract void recover(TopologyRecording topologyRecording)