org.codehaus.activemq.ra
Class ActiveMQAsfEndpointWorker.ServerSessionImpl

java.lang.Object
  org.codehaus.activemq.ra.ActiveMQAsfEndpointWorker.ServerSessionImpl

All Implemented Interfaces:

MessageListener, java.lang.Runnable, ServerSession, Work

Enclosing class:

ActiveMQAsfEndpointWorker

class ActiveMQAsfEndpointWorker.ServerSessionImpl

extends java.lang.Object

implements ServerSession, Work, MessageListener

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 session

workPendingFlag

boolean workPendingFlag

runningFlag

boolean runningFlag

runCounter

int runCounter

xaResource

XAResource xaResource

Constructor Detail

ActiveMQAsfEndpointWorker.ServerSessionImpl

public ActiveMQAsfEndpointWorker.ServerSessionImpl(ActiveMQAsfEndpointWorker.ServerSessionPoolImpl pool,
                                                   Session session)
                                            throws JMSException

Method Detail

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 java.lang.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 java.lang.String toString()

See Also:

Object.toString()