Package org.apache.activemq.ra

Class ActiveMQEndpointWorker

java.lang.Object

org.apache.activemq.ra.ActiveMQEndpointWorker

public class ActiveMQEndpointWorker
extends Object

$Date$

Field Summary

Fields

Modifier and Type	Field	Description
protected final ActiveMQEndpointActivationKey	endpointActivationKey
protected final jakarta.resource.spi.endpoint.MessageEndpointFactory	endpointFactory
static final Method	ON_MESSAGE_METHOD
protected final boolean	transacted
protected final jakarta.resource.spi.work.WorkManager	workManager

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected org.apache.activemq.ActiveMQConnection	getConnection()
protected void	registerThreadSession(jakarta.jms.Session session)
static void	safeClose(jakarta.jms.Connection c)
static void	safeClose(jakarta.jms.ConnectionConsumer cc)
void	setConnection(org.apache.activemq.ActiveMQConnection activeMQConnection)
void	start()
void	stop()
protected void	unregisterThreadSession(jakarta.jms.Session session)

Methods inherited from class java.lang.Object

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

Field Details

ON_MESSAGE_METHOD

public static final Method ON_MESSAGE_METHOD

endpointActivationKey

protected final ActiveMQEndpointActivationKey endpointActivationKey

endpointFactory

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

workManager

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

transacted

protected final boolean transacted

Constructor Details

ActiveMQEndpointWorker

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

Throws:

jakarta.resource.ResourceException

Method Details

safeClose

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

Parameters:

c -

safeClose

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

Parameters:

cc -

start

public void start()
           throws jakarta.resource.ResourceException

Throws:

jakarta.resource.ResourceException

stop

public void stop()
          throws InterruptedException

Throws:

InterruptedException

registerThreadSession

protected void registerThreadSession(jakarta.jms.Session session)

unregisterThreadSession

protected void unregisterThreadSession(jakarta.jms.Session session)

setConnection

public void setConnection(org.apache.activemq.ActiveMQConnection activeMQConnection)

getConnection

protected org.apache.activemq.ActiveMQConnection getConnection()