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 java.lang.String	COUNT_BASED_SENDING
protected boolean	createNewMsg
static java.lang.String	DELIVERY_MODE_NON_PERSISTENT
static java.lang.String	DELIVERY_MODE_PERSISTENT
protected java.lang.String	deliveryMode
protected java.util.Map<java.lang.String,java.lang.Object>	headerMap
protected int	messageSize
protected java.lang.String	msgFileName
protected long	sendCount
protected long	sendDelay
protected long	sendDuration
protected java.lang.String	sendType
static java.lang.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()
java.lang.String	getDeliveryMode()
java.util.Set<java.lang.String>	getHeaderKeys()
java.lang.Object	getHeaderValue(java.lang.String key)
int	getMessageSize()
java.lang.String	getMsgFileName()
long	getSendCount()
long	getSendDelay()
long	getSendDuration()
java.lang.String	getSendType()
boolean	isCreateNewMsg()
void	setCreateNewMsg(boolean createNewMsg)
void	setDeliveryMode(java.lang.String deliveryMode)
void	setHeader(java.lang.String encodedHeader) Method for setting a message header.
void	setMessageSize(int messageSize)
void	setMsgFileName(java.lang.String file)
void	setSendCount(long sendCount)
void	setSendDelay(long delay)
void	setSendDuration(long sendDuration)
void	setSendType(java.lang.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 java.lang.String TIME_BASED_SENDING

See Also:

Constant Field Values

COUNT_BASED_SENDING

public static final java.lang.String COUNT_BASED_SENDING

See Also:

Constant Field Values

DELIVERY_MODE_PERSISTENT

public static final java.lang.String DELIVERY_MODE_PERSISTENT

See Also:

Constant Field Values

DELIVERY_MODE_NON_PERSISTENT

public static final java.lang.String DELIVERY_MODE_NON_PERSISTENT

See Also:

Constant Field Values

deliveryMode

protected java.lang.String deliveryMode

messageSize

protected int messageSize

sendCount

protected long sendCount

sendDuration

protected long sendDuration

sendType

protected java.lang.String sendType

sendDelay

protected long sendDelay

msgFileName

protected java.lang.String msgFileName

headerMap

protected java.util.Map<java.lang.String,java.lang.Object> headerMap

createNewMsg

protected boolean createNewMsg

Constructor Detail

JmsProducerProperties

public JmsProducerProperties()

Method Detail

getDeliveryMode

public java.lang.String getDeliveryMode()

setDeliveryMode

public void setDeliveryMode(java.lang.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 java.lang.String getSendType()

setSendType

public void setSendType(java.lang.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(java.lang.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 java.util.Set<java.lang.String> getHeaderKeys()

getHeaderValue

public java.lang.Object getHeaderValue(java.lang.String key)

clearHeaders

public void clearHeaders()

setMsgFileName

public void setMsgFileName(java.lang.String file)

getMsgFileName

public java.lang.String getMsgFileName()