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.MessageConsumerComponent  

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

All Implemented Interfaces:

javax.jms.MessageListener, java.lang.Runnable

Enclosing class:

BecksNetworkTest

---

private static final class BecksNetworkTest.MessageConsumerComponent

extends BecksNetworkTest.JMSComponent

implements javax.jms.MessageListener

---

Nested Class Summary

 

Nested classes inherited from class java.lang.Thread

java.lang.Thread.UncaughtExceptionHandler

 

Field Summary
protected  javax.jms.Connection	m_connection
private  javax.jms.MessageConsumer	m_consumer
protected  java.lang.String	m_id
private  boolean	m_inOnMessage
private  int	m_numMessagesConsumed
protected  javax.jms.Queue	m_queue
protected  javax.jms.Session	m_session
protected  BecksNetworkTest.SimulationState	m_simulationState
private  java.lang.Object	m_stateLock
protected  java.lang.String	m_url

 

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

 

Constructor Summary

BecksNetworkTest.MessageConsumerComponent(BecksNetworkTest.SimulationState state, java.lang.String id, java.lang.String url)

 

Method Summary
protected  void	_cleanup()
protected  void	_initialize()
void	_run()
java.lang.String	getId()           Returns the unique identifier for this thread.
int	getNumberOfMessagesConsumed()
void	onMessage(javax.jms.Message msg)
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_stateLock

private final java.lang.Object m_stateLock

---

m_inOnMessage

private boolean m_inOnMessage

---

m_consumer

private javax.jms.MessageConsumer m_consumer

---

m_numMessagesConsumed

private int m_numMessagesConsumed

---

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.MessageConsumerComponent

public BecksNetworkTest.MessageConsumerComponent(BecksNetworkTest.SimulationState state,
                                                 java.lang.String id,
                                                 java.lang.String url)

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 java.lang.InterruptedException

Specified by:

_run in class BecksNetworkTest.SimulationComponent

---

getNumberOfMessagesConsumed

public int getNumberOfMessagesConsumed()

---

onMessage

public void onMessage(javax.jms.Message msg)

Specified by:

onMessage in interface javax.jms.MessageListener

---

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

---