|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.ra.ActiveMQAsfEndpointWorker.ServerSessionImpl
Field Summary | |
(package private) int |
runCounter
|
(package private) boolean |
runningFlag
|
(package private) Session |
session
|
(package private) boolean |
workPendingFlag
|
(package private) XAResource |
xaResource
|
Constructor Summary | |
ActiveMQAsfEndpointWorker.ServerSessionImpl(ActiveMQAsfEndpointWorker.ServerSessionPoolImpl pool,
Session session)
|
Method Summary | |
Session |
getSession()
|
void |
onMessage(Message message)
|
void |
release()
|
void |
run()
|
void |
start()
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
Session session
boolean workPendingFlag
boolean runningFlag
int runCounter
XAResource xaResource
Constructor Detail |
public ActiveMQAsfEndpointWorker.ServerSessionImpl(ActiveMQAsfEndpointWorker.ServerSessionPoolImpl pool, Session session) throws JMSException
Method Detail |
public Session getSession() throws JMSException
getSession
in interface ServerSession
JMSException
ServerSession.getSession()
public void start() throws JMSException
start
in interface ServerSession
JMSException
ServerSession.start()
public void run()
run
in interface java.lang.Runnable
Runnable.run()
public void release()
release
in interface Work
Work.release()
public void onMessage(Message message)
onMessage
in interface MessageListener
MessageListener.onMessage(javax.jms.Message)
public java.lang.String toString()
Object.toString()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |