org.apache.activemq.ra

Class ActiveMQEndpointWorker

java.lang.Object

org.apache.activemq.ra.ActiveMQEndpointWorker

public class ActiveMQEndpointWorker
extends java.lang.Object

$Date$

Field Summary

Fields

Modifier and Type	Field and Description
protected ActiveMQEndpointActivationKey	endpointActivationKey
protected javax.resource.spi.endpoint.MessageEndpointFactory	endpointFactory
static java.lang.reflect.Method	ON_MESSAGE_METHOD
protected boolean	transacted
protected javax.resource.spi.work.WorkManager	workManager

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ActiveMQEndpointWorker(MessageResourceAdapter adapter, ActiveMQEndpointActivationKey key)

Method Summary

Methods

Modifier and Type	Method and Description
protected ActiveMQConnection	getConnection()
protected void	registerThreadSession(javax.jms.Session session)
static void	safeClose(javax.jms.Connection c)
static void	safeClose(javax.jms.ConnectionConsumer cc)
void	start()
void	stop()
protected void	unregisterThreadSession(javax.jms.Session session)

Methods inherited from class java.lang.Object

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

Field Detail

ON_MESSAGE_METHOD

public static final java.lang.reflect.Method ON_MESSAGE_METHOD

endpointActivationKey

protected final ActiveMQEndpointActivationKey endpointActivationKey

endpointFactory

protected final javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory

workManager

protected final javax.resource.spi.work.WorkManager workManager

transacted

protected final boolean transacted

Constructor Detail

ActiveMQEndpointWorker

protected ActiveMQEndpointWorker(MessageResourceAdapter adapter,
                      ActiveMQEndpointActivationKey key)
                          throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

Method Detail

safeClose

public static void safeClose(javax.jms.Connection c)

Parameters:

c -

safeClose

public static void safeClose(javax.jms.ConnectionConsumer cc)

Parameters:

cc -

start

public void start()
           throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

stop

public void stop()
          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

registerThreadSession

protected void registerThreadSession(javax.jms.Session session)

unregisterThreadSession

protected void unregisterThreadSession(javax.jms.Session session)

getConnection

protected ActiveMQConnection getConnection()