org.apache.activemq.tool
Class JmsProducerClient
java.lang.Object
org.apache.activemq.tool.AbstractJmsClient
org.apache.activemq.tool.AbstractJmsMeasurableClient
org.apache.activemq.tool.JmsProducerClient
- All Implemented Interfaces:
- MeasurableClient
public class JmsProducerClient
- extends AbstractJmsMeasurableClient
Methods inherited from class org.apache.activemq.tool.AbstractJmsClient |
createCompositeDestination, createCompositeDestination, createDestination, createDestination, getClientName, getConnection, getDestCount, getDestIndex, getFactory, getSession, setClientName, setDestCount, setDestIndex, setFactory |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
client
protected JmsProducerProperties client
jmsProducer
protected MessageProducer jmsProducer
jmsTextMessage
protected TextMessage jmsTextMessage
JmsProducerClient
public JmsProducerClient(ConnectionFactory factory)
JmsProducerClient
public JmsProducerClient(JmsProducerProperties clientProps,
ConnectionFactory factory)
sendMessages
public void sendMessages()
throws JMSException
- Throws:
JMSException
sendMessages
public void sendMessages(int destCount)
throws JMSException
- Throws:
JMSException
sendMessages
public void sendMessages(int destIndex,
int destCount)
throws JMSException
- Throws:
JMSException
sendCountBasedMessages
public void sendCountBasedMessages(long messageCount)
throws JMSException
- Throws:
JMSException
sendTimeBasedMessages
public void sendTimeBasedMessages(long duration)
throws JMSException
- Throws:
JMSException
createJmsProducer
public MessageProducer createJmsProducer()
throws JMSException
- Throws:
JMSException
createJmsProducer
public MessageProducer createJmsProducer(Destination dest)
throws JMSException
- Throws:
JMSException
getJmsProducer
public MessageProducer getJmsProducer()
createJmsTextMessage
public TextMessage createJmsTextMessage()
throws JMSException
- Throws:
JMSException
createJmsTextMessage
public TextMessage createJmsTextMessage(int size)
throws JMSException
- Throws:
JMSException
createJmsTextMessage
public TextMessage createJmsTextMessage(String text)
throws JMSException
- Throws:
JMSException
getJmsTextMessage
public TextMessage getJmsTextMessage()
getClient
public JmsClientProperties getClient()
- Specified by:
getClient
in class AbstractJmsClient
setClient
public void setClient(JmsClientProperties clientProps)
- Specified by:
setClient
in class AbstractJmsClient
buildText
protected String buildText(String text,
int size)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.