com.rabbitmq.perf

Class Consumer

java.lang.Object

com.rabbitmq.perf.AgentBase

com.rabbitmq.perf.Consumer

All Implemented Interfaces:

java.lang.Runnable

public class Consumer
extends AgentBase
implements java.lang.Runnable

Nested Class Summary

Nested classes/interfaces inherited from class com.rabbitmq.perf.AgentBase

AgentBase.AgentState

Constructor Summary

Constructors

Constructor and Description
Consumer(ConsumerParameters parameters)

Method Summary

Modifier and Type	Method and Description
void	recover(TopologyRecording topologyRecording)
void	run()
protected StartListener.Type	type()

Methods inherited from class com.rabbitmq.perf.AgentBase

dealWithWriteOperation, handleShutdownSignalExceptionOnWrite, isConnectionRecoveryTriggered, setTopologyRecording, shouldStop, started, topologyRecording

Methods inherited from class java.lang.Object

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

Constructor Detail

Consumer

public Consumer(ConsumerParameters parameters)

Method Detail

type

protected StartListener.Type type()

Specified by:

type in class AgentBase

run

public void run()

Specified by:

run in interface java.lang.Runnable

recover

public void recover(TopologyRecording topologyRecording)

Specified by:

recover in class AgentBase