com.rabbitmq.perf

Class Producer

java.lang.Object

com.rabbitmq.perf.AgentBase

com.rabbitmq.perf.Producer

All Implemented Interfaces:

com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnListener, java.lang.Runnable

public class Producer
extends AgentBase
implements java.lang.Runnable, com.rabbitmq.client.ReturnListener, com.rabbitmq.client.ConfirmListener

Nested Class Summary

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

AgentBase.AgentState

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	APP_ID_PROPERTY
static java.lang.String	CLUSTER_ID_PROPERTY
static java.lang.String	CONTENT_ENCODING_PROPERTY
static java.lang.String	CONTENT_TYPE_PROPERTY
static java.lang.String	CORRELATION_ID_PROPERTY
static java.lang.String	DELIVERY_MODE_PROPERTY
static java.lang.String	EXPIRATION_PROPERTY
static java.lang.String	MESSAGE_ID_PROPERTY
static java.lang.String	PRIORITY_PROPERTY
static java.lang.String	REPLY_TO_PROPERTY
static java.lang.String	TIMESTAMP_HEADER
static java.lang.String	TIMESTAMP_PROPERTY
static java.lang.String	TYPE_PROPERTY
static java.lang.String	USER_ID_PROPERTY

Constructor Summary

Constructors

Constructor and Description
Producer(ProducerParameters parameters)

Method Summary

Modifier and Type	Method and Description
java.lang.Runnable	createRunnableForScheduling()
void	handleAck(long seqNo, boolean multiple)
void	handleNack(long seqNo, boolean multiple)
void	handlePublish(AgentBase.AgentState currentState)
void	handleReturn(int replyCode, java.lang.String replyText, java.lang.String exchange, java.lang.String routingKey, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body)
void	maybeHandlePublish(AgentBase.AgentState state)
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

Field Detail

TIMESTAMP_PROPERTY

public static final java.lang.String TIMESTAMP_PROPERTY

See Also:

Constant Field Values

CONTENT_TYPE_PROPERTY

public static final java.lang.String CONTENT_TYPE_PROPERTY

See Also:

Constant Field Values

CONTENT_ENCODING_PROPERTY

public static final java.lang.String CONTENT_ENCODING_PROPERTY

See Also:

Constant Field Values

DELIVERY_MODE_PROPERTY

public static final java.lang.String DELIVERY_MODE_PROPERTY

See Also:

Constant Field Values

PRIORITY_PROPERTY

public static final java.lang.String PRIORITY_PROPERTY

See Also:

Constant Field Values

CORRELATION_ID_PROPERTY

public static final java.lang.String CORRELATION_ID_PROPERTY

See Also:

Constant Field Values

REPLY_TO_PROPERTY

public static final java.lang.String REPLY_TO_PROPERTY

See Also:

Constant Field Values

EXPIRATION_PROPERTY

public static final java.lang.String EXPIRATION_PROPERTY

See Also:

Constant Field Values

MESSAGE_ID_PROPERTY

public static final java.lang.String MESSAGE_ID_PROPERTY

See Also:

Constant Field Values

TYPE_PROPERTY

public static final java.lang.String TYPE_PROPERTY

See Also:

Constant Field Values

USER_ID_PROPERTY

public static final java.lang.String USER_ID_PROPERTY

See Also:

Constant Field Values

APP_ID_PROPERTY

public static final java.lang.String APP_ID_PROPERTY

See Also:

Constant Field Values

CLUSTER_ID_PROPERTY

public static final java.lang.String CLUSTER_ID_PROPERTY

See Also:

Constant Field Values

TIMESTAMP_HEADER

public static final java.lang.String TIMESTAMP_HEADER

See Also:

Constant Field Values

Constructor Detail

Producer

public Producer(ProducerParameters parameters)

Method Detail

type

protected StartListener.Type type()

Specified by:

type in class AgentBase

handleReturn

public void handleReturn(int replyCode,
                         java.lang.String replyText,
                         java.lang.String exchange,
                         java.lang.String routingKey,
                         com.rabbitmq.client.AMQP.BasicProperties properties,
                         byte[] body)

Specified by:

handleReturn in interface com.rabbitmq.client.ReturnListener

handleAck

public void handleAck(long seqNo,
                      boolean multiple)

Specified by:

handleAck in interface com.rabbitmq.client.ConfirmListener

handleNack

public void handleNack(long seqNo,
                       boolean multiple)

Specified by:

handleNack in interface com.rabbitmq.client.ConfirmListener

run

public void run()

Specified by:

run in interface java.lang.Runnable

createRunnableForScheduling

public java.lang.Runnable createRunnableForScheduling()

maybeHandlePublish

public void maybeHandlePublish(AgentBase.AgentState state)

handlePublish

public void handlePublish(AgentBase.AgentState currentState)

recover

public void recover(TopologyRecording topologyRecording)

Specified by:

recover in class AgentBase