org.apache.activemq.tool.properties

Class JmsProducerProperties

java.lang.Object

org.apache.activemq.tool.properties.AbstractObjectProperties

org.apache.activemq.tool.properties.JmsClientProperties

org.apache.activemq.tool.properties.JmsProducerProperties

All Implemented Interfaces:

ReflectionConfigurable

public class JmsProducerProperties
extends JmsClientProperties

Field Summary

Fields

Modifier and Type	Field and Description
static String	COUNT_BASED_SENDING
protected boolean	createNewMsg
static String	DELIVERY_MODE_NON_PERSISTENT
static String	DELIVERY_MODE_PERSISTENT
protected String	deliveryMode
protected Map<String,Object>	headerMap
protected int	messageSize
protected String	msgFileName
protected long	sendCount
protected long	sendDelay
protected long	sendDuration
protected String	sendType
static String	TIME_BASED_SENDING

Fields inherited from class org.apache.activemq.tool.properties.JmsClientProperties

commitAfterXMsgs, destComposite, destName, jmsProperties, jmsProvider, jmsVersion, sessAckMode, SESSION_AUTO_ACKNOWLEDGE, SESSION_CLIENT_ACKNOWLEDGE, SESSION_DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED, sessTransacted

Constructor Summary

Constructors

Constructor and Description
JmsProducerProperties()

Method Summary

Methods

Modifier and Type	Method and Description
void	clearHeaders()
String	getDeliveryMode()
Set<String>	getHeaderKeys()
Object	getHeaderValue(String key)
int	getMessageSize()
String	getMsgFileName()
long	getSendCount()
long	getSendDelay()
long	getSendDuration()
String	getSendType()
boolean	isCreateNewMsg()
void	setCreateNewMsg(boolean createNewMsg)
void	setDeliveryMode(String deliveryMode)
void	setHeader(String encodedHeader) Method for setting a message header.
void	setMessageSize(int messageSize)
void	setMsgFileName(String file)
void	setSendCount(long sendCount)
void	setSendDelay(long delay)
void	setSendDuration(long sendDuration)
void	setSendType(String sendType)

Methods inherited from class org.apache.activemq.tool.properties.JmsClientProperties

getCommitAfterXMsgs, getDestName, getJmsProperties, getJmsProvider, getJmsVersion, getSessAckMode, isDestComposite, isSessTransacted, setCommitAfterXMsgs, setDestComposite, setDestName, setJmsProperties, setJmsProvider, setJmsVersion, setSessAckMode, setSessTransacted

Methods inherited from class org.apache.activemq.tool.properties.AbstractObjectProperties

acceptConfig, configureProperties, retrieveProperties

Methods inherited from class java.lang.Object

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

Field Detail

TIME_BASED_SENDING

public static final String TIME_BASED_SENDING

See Also:

Constant Field Values

COUNT_BASED_SENDING

public static final String COUNT_BASED_SENDING

See Also:

Constant Field Values

DELIVERY_MODE_PERSISTENT

public static final String DELIVERY_MODE_PERSISTENT

See Also:

Constant Field Values

DELIVERY_MODE_NON_PERSISTENT

public static final String DELIVERY_MODE_NON_PERSISTENT

See Also:

Constant Field Values

deliveryMode

protected String deliveryMode

messageSize

protected int messageSize

sendCount

protected long sendCount

sendDuration

protected long sendDuration

sendType

protected String sendType

sendDelay

protected long sendDelay

msgFileName

protected String msgFileName

headerMap

protected Map<String,Object> headerMap

createNewMsg

protected boolean createNewMsg

Constructor Detail

JmsProducerProperties

public JmsProducerProperties()

Method Detail

getDeliveryMode

public String getDeliveryMode()

setDeliveryMode

public void setDeliveryMode(String deliveryMode)

getMessageSize

public int getMessageSize()

setMessageSize

public void setMessageSize(int messageSize)

getSendCount

public long getSendCount()

setSendCount

public void setSendCount(long sendCount)

getSendDuration

public long getSendDuration()

setSendDuration

public void setSendDuration(long sendDuration)

getSendType

public String getSendType()

setSendType

public void setSendType(String sendType)

isCreateNewMsg

public boolean isCreateNewMsg()

setCreateNewMsg

public void setCreateNewMsg(boolean createNewMsg)

setSendDelay

public void setSendDelay(long delay)

getSendDelay

public long getSendDelay()

setHeader

public void setHeader(String encodedHeader)

Method for setting a message header.

Parameters:

encodedHeader - - the header is encoded as a string using this syntax: encodedHeader = [headerkey '=' headervalue ':' ]* E.g. an encodedHeader could read "JMSType=car", or "JMSType=car:MyHeader=MyValue" That implies neither the header key nor the value can contain any of the characters ':' and '='.

getHeaderKeys

public Set<String> getHeaderKeys()

getHeaderValue

public Object getHeaderValue(String key)

clearHeaders

public void clearHeaders()

setMsgFileName

public void setMsgFileName(String file)

getMsgFileName

public String getMsgFileName()