org.apache.activemq.tool.properties
Class JmsProducerProperties

java.lang.Object
  extended by org.apache.activemq.tool.properties.AbstractObjectProperties
      extended by org.apache.activemq.tool.properties.JmsClientProperties
          extended by org.apache.activemq.tool.properties.JmsProducerProperties
All Implemented Interfaces:
ReflectionConfigurable

public class JmsProducerProperties
extends JmsClientProperties


Field Summary
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
JmsProducerProperties()
           
 
Method Summary
 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()


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.