Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ usecases overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.usecases
Class BecksNetworkTest.MessageProducerComponent  

java.lang.Object
  java.lang.Thread
      org.activemq.usecases.BecksNetworkTest.SimulationComponent
          org.activemq.usecases.BecksNetworkTest.JMSComponent
              org.activemq.usecases.BecksNetworkTest.MessageProducerComponent

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

BecksNetworkTest

---

private static final class BecksNetworkTest.MessageProducerComponent

extends BecksNetworkTest.JMSComponent

---

Nested Class Summary

 

Nested classes inherited from class java.lang.Thread

java.lang.Thread.UncaughtExceptionHandler

 

Field Summary
protected  javax.jms.Connection	m_connection
protected  java.lang.String	m_id
private  int	m_numMessagesToSend
private  javax.jms.MessageProducer	m_producer
protected  javax.jms.Queue	m_queue
protected  javax.jms.Session	m_session
protected  BecksNetworkTest.SimulationState	m_simulationState
protected  java.lang.String	m_url

 

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

 

Constructor Summary

BecksNetworkTest.MessageProducerComponent(BecksNetworkTest.SimulationState state, java.lang.String id, java.lang.String url, int numMessages)

 

Method Summary
protected  void	_cleanup()
protected  void	_initialize()
void	_run()
private static java.lang.String	createMessageBody(java.lang.String id, int num)
java.lang.String	getId()           Returns the unique identifier for this thread.
void	run()           The method of Thread that will be run if there is no Runnable object associated with the Thread.

 

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getDefaultUncaughtExceptionHandler, getName, getPriority, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

 

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

 

Field Detail

m_numMessagesToSend

private final int m_numMessagesToSend

---

m_producer

private javax.jms.MessageProducer m_producer

---

m_url

protected final java.lang.String m_url

---

m_connection

protected javax.jms.Connection m_connection

---

m_session

protected javax.jms.Session m_session

---

m_queue

protected javax.jms.Queue m_queue

---

m_simulationState

protected final BecksNetworkTest.SimulationState m_simulationState

---

m_id

protected final java.lang.String m_id

Constructor Detail

BecksNetworkTest.MessageProducerComponent

public BecksNetworkTest.MessageProducerComponent(BecksNetworkTest.SimulationState state,
                                                 java.lang.String id,
                                                 java.lang.String url,
                                                 int numMessages)

Method Detail

_initialize

protected void _initialize()
                    throws javax.jms.JMSException

Overrides:

_initialize in class BecksNetworkTest.JMSComponent

---

_cleanup

protected void _cleanup()
                 throws javax.jms.JMSException

Overrides:

_cleanup in class BecksNetworkTest.JMSComponent

---

_run

public void _run()
          throws javax.jms.JMSException,
                 java.lang.InterruptedException

Specified by:

_run in class BecksNetworkTest.SimulationComponent

---

createMessageBody

private static java.lang.String createMessageBody(java.lang.String id,
                                                  int num)

---

getId

public java.lang.String getId()

Description copied from class: java.lang.Thread

Returns the unique identifier for this thread. This ID is generated on thread creation, and may be re-used on its death.

---

run

public final void run()

Description copied from class: java.lang.Thread

The method of Thread that will be run if there is no Runnable object associated with the Thread. Thread's implementation does nothing at all.

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ usecases overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---