org.codehaus.activemq.ra
Class ActiveMQAsfEndpointWorker.ServerSessionImpl
java.lang.Object
org.codehaus.activemq.ra.ActiveMQAsfEndpointWorker.ServerSessionImpl
- All Implemented Interfaces:
- MessageListener, Runnable, ServerSession, Work
- Enclosing class:
- ActiveMQAsfEndpointWorker
- class ActiveMQAsfEndpointWorker.ServerSessionImpl
- extends Object
- implements ServerSession, Work, MessageListener
session
Session session
workPendingFlag
boolean workPendingFlag
runningFlag
boolean runningFlag
runCounter
int runCounter
xaResource
XAResource xaResource
ActiveMQAsfEndpointWorker.ServerSessionImpl
public ActiveMQAsfEndpointWorker.ServerSessionImpl(ActiveMQAsfEndpointWorker.ServerSessionPoolImpl pool,
Session session)
throws JMSException
getSession
public Session getSession()
throws JMSException
- Specified by:
getSession
in interface ServerSession
- Throws:
JMSException
- See Also:
ServerSession.getSession()
start
public void start()
throws JMSException
- Specified by:
start
in interface ServerSession
- Throws:
JMSException
- See Also:
ServerSession.start()
run
public void run()
- Specified by:
run
in interface Runnable
- See Also:
Runnable.run()
release
public void release()
- Specified by:
release
in interface Work
- See Also:
Work.release()
onMessage
public void onMessage(Message message)
- Specified by:
onMessage
in interface MessageListener
- See Also:
MessageListener.onMessage(javax.jms.Message)
toString
public String toString()
- See Also:
Object.toString()
Copyright © 2004 Protique, Ltd.. All Rights Reserved.