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()
           
protected  TextMessage loadJmsMessage()
          loads the message to be sent from the specified TextFile
 void sendCountBasedMessages(long messageCount)
           
 void sendMessages()
           
 void sendMessages(int destCount)
           
 void sendMessages(int destIndex, int destCount)
           
 void sendTimeBasedMessages(long duration)
           
 void setClient(JmsClientProperties clientProps)
           
protected  void sleep()
           
 
Methods inherited from class org.apache.activemq.tool.AbstractJmsMeasurableClient
getThroughput, incThroughput, incThroughput, reset, setThroughput
 
Methods inherited from class org.apache.activemq.tool.AbstractJmsClient
commitTxIfNecessary, 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)

sleep

protected void sleep()

loadJmsMessage

protected TextMessage loadJmsMessage()
                              throws JMSException
loads the message to be sent from the specified TextFile

Throws:
JMSException


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.