org.apache.activemq.ra
Class ActiveMQEndpointWorker

java.lang.Object
  extended by org.apache.activemq.ra.ActiveMQEndpointWorker

public class ActiveMQEndpointWorker
extends java.lang.Object

Version:
$Revision$ $Date$

Field Summary
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
ActiveMQEndpointWorker(ActiveMQResourceAdapter adapter, ActiveMQEndpointActivationKey key)
           
 
Method Summary
protected  void registerThreadSession(javax.jms.Session session)
           
static void safeClose(javax.jms.Session s)
           
 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

public ActiveMQEndpointWorker(ActiveMQResourceAdapter adapter,
                              ActiveMQEndpointActivationKey key)
                       throws javax.resource.ResourceException
Throws:
javax.resource.ResourceException
Method Detail

safeClose

public static void safeClose(javax.jms.Session s)
Parameters:
s - session to close

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)


Copyright © 2009 Apache Software Foundation. All Rights Reserved.