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 ActiveMQEndpointActivationKey	endpointActivationKey
protected MessageEndpointFactory	endpointFactory
static Method	ON_MESSAGE_METHOD
protected boolean	transacted
protected WorkManager	workManager

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected ActiveMQConnection	getConnection()
protected void	registerThreadSession(Session session)
static void	safeClose(Connection c)
static void	safeClose(ConnectionConsumer cc)
void	setConnection(ActiveMQConnection activeMQConnection)
void	start()
void	stop()
protected void	unregisterThreadSession(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 Method ON_MESSAGE_METHOD

endpointActivationKey

protected final ActiveMQEndpointActivationKey endpointActivationKey

endpointFactory

protected final MessageEndpointFactory endpointFactory

workManager

protected final WorkManager workManager

transacted

protected final boolean transacted

Constructor Detail

ActiveMQEndpointWorker

protected ActiveMQEndpointWorker(MessageResourceAdapter adapter,
                                 ActiveMQEndpointActivationKey key)
                          throws ResourceException

Throws:

ResourceException

Method Detail

safeClose

public static void safeClose(Connection c)

Parameters:

c -

safeClose

public static void safeClose(ConnectionConsumer cc)

Parameters:

cc -

start

public void start()
           throws ResourceException

Throws:

ResourceException

stop

public void stop()
          throws InterruptedException

Throws:

InterruptedException

registerThreadSession

protected void registerThreadSession(Session session)

unregisterThreadSession

protected void unregisterThreadSession(Session session)

setConnection

public void setConnection(ActiveMQConnection activeMQConnection)

getConnection

protected ActiveMQConnection getConnection()