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

---

org.activemq
Class ActiveMQSessionExecutor  

java.lang.Object
  org.activemq.ActiveMQSessionExecutor

All Implemented Interfaces:

java.lang.Runnable

---

public class ActiveMQSessionExecutor

extends java.lang.Object

implements java.lang.Runnable

A utility class used by the Session for dispatching messages asynchronously to consumers

Version:

$Revision: 1.1.1.1 $

---

Field Summary
private  boolean	closed
private  boolean	dispatchedBySessionPool
private  org.activemq.io.util.MemoryBoundedQueue	messageQueue
private  boolean	optimizedMessageDispatch
private  java.lang.Thread	runner
private  ActiveMQSession	session

 

Constructor Summary
(package private)	ActiveMQSessionExecutor(ActiveMQSession session, org.activemq.io.util.MemoryBoundedQueue queue)

 

Method Summary
(package private)  void	clear()
protected  void	clearMessagesInProgress()
(package private)  void	close()
(package private)  org.activemq.message.ActiveMQMessage	dequeueNoWait()
(package private)  void	dispatch(org.activemq.message.ActiveMQMessage message)
(package private)  void	execute(org.activemq.message.ActiveMQMessage message)
(package private)  void	executeFirst(org.activemq.message.ActiveMQMessage message)
(package private)  java.util.List	getUnconsumedMessages()
(package private)  boolean	hasUncomsumedMessages()
(package private)  boolean	isOptimizedMessageDispatch()
void	run()           implementation of Runnable
(package private)  void	setDispatchedBySessionPool(boolean value)
(package private)  void	setOptimizedMessageDispatch(boolean optimizedMessageDispatch)
(package private)  void	start()
(package private)  void	stop()

 

Methods inherited from class java.lang.Object

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

 

Field Detail

session

private ActiveMQSession session

---

messageQueue

private org.activemq.io.util.MemoryBoundedQueue messageQueue

---

closed

private boolean closed

---

runner

private java.lang.Thread runner

---

dispatchedBySessionPool

private boolean dispatchedBySessionPool

---

optimizedMessageDispatch

private boolean optimizedMessageDispatch

Constructor Detail

ActiveMQSessionExecutor

ActiveMQSessionExecutor(ActiveMQSession session,
                        org.activemq.io.util.MemoryBoundedQueue queue)

Method Detail

setDispatchedBySessionPool

void setDispatchedBySessionPool(boolean value)

---

isOptimizedMessageDispatch

boolean isOptimizedMessageDispatch()

---

setOptimizedMessageDispatch

void setOptimizedMessageDispatch(boolean optimizedMessageDispatch)

---

execute

void execute(org.activemq.message.ActiveMQMessage message)

---

executeFirst

void executeFirst(org.activemq.message.ActiveMQMessage message)

---

hasUncomsumedMessages

boolean hasUncomsumedMessages()

---

getUnconsumedMessages

java.util.List getUnconsumedMessages()

---

run

public void run()

implementation of Runnable

Specified by:

run in interface java.lang.Runnable

---

dispatch

void dispatch(org.activemq.message.ActiveMQMessage message)

---

start

void start()

---

stop

void stop()

---

close

void close()

---

clear

void clear()

---

dequeueNoWait

org.activemq.message.ActiveMQMessage dequeueNoWait()

---

clearMessagesInProgress

protected void clearMessagesInProgress()

---

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

---