org.apache.activemq.tool
Class JmsProducerClient

java.lang.Object
  extended by org.apache.activemq.tool.AbstractJmsClient
      extended by org.apache.activemq.tool.AbstractJmsMeasurableClient
          extended by org.apache.activemq.tool.JmsProducerClient
All Implemented Interfaces:
MeasurableClient

public class JmsProducerClient
extends AbstractJmsMeasurableClient


Field Summary
protected  JmsProducerProperties client
           
protected  MessageProducer jmsProducer
           
protected  TextMessage jmsTextMessage
           
 
Fields inherited from class org.apache.activemq.tool.AbstractJmsMeasurableClient
throughput
 
Fields inherited from class org.apache.activemq.tool.AbstractJmsClient
clientName, destCount, destIndex, factory, jmsConnection, jmsSession
 
Constructor Summary
JmsProducerClient(ConnectionFactory factory)
           
JmsProducerClient(JmsProducerProperties clientProps, ConnectionFactory factory)
           
 
Method Summary
protected  String buildText(String text, int size)
           
 MessageProducer createJmsProducer()
           
 MessageProducer createJmsProducer(Destination dest)
           
 TextMessage createJmsTextMessage()
           
 TextMessage createJmsTextMessage(int size)
           
 TextMessage createJmsTextMessage(String text)
           
 JmsClientProperties getClient()
           
 MessageProducer getJmsProducer()
           
 TextMessage getJmsTextMessage()
           
 void sendCountBasedMessages(long messageCount)
           
 void sendMessages()
           
 void sendMessages(int destCount)
           
 void sendMessages(int destIndex, int destCount)
           
 void sendTimeBasedMessages(long duration)
           
 void setClient(JmsClientProperties clientProps)
           
 
Methods inherited from class org.apache.activemq.tool.AbstractJmsMeasurableClient
getThroughput, incThroughput, incThroughput, reset, setThroughput
 
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
 
Methods inherited from interface org.apache.activemq.tool.sampler.MeasurableClient
getClientName
 

Field Detail

client

protected JmsProducerProperties client

jmsProducer

protected MessageProducer jmsProducer

jmsTextMessage

protected TextMessage jmsTextMessage
Constructor Detail

JmsProducerClient

public JmsProducerClient(ConnectionFactory factory)

JmsProducerClient

public JmsProducerClient(JmsProducerProperties clientProps,
                         ConnectionFactory factory)
Method Detail

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.