org.apache.activemq.ra
Class ActiveMQEndpointWorker

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

public class ActiveMQEndpointWorker
extends Object

$Date$


Field Summary
protected  ActiveMQEndpointActivationKey endpointActivationKey
           
protected  MessageEndpointFactory endpointFactory
           
static Method ON_MESSAGE_METHOD
           
protected  boolean transacted
           
protected  WorkManager workManager
           
 
Constructor Summary
protected ActiveMQEndpointWorker(MessageResourceAdapter adapter, ActiveMQEndpointActivationKey key)
           
 
Method Summary
protected  ActiveMQConnection getConnection()
           
protected  void registerThreadSession(Session session)
           
static void safeClose(Connection c)
           
static void safeClose(ConnectionConsumer cc)
           
 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)

getConnection

protected ActiveMQConnection getConnection()


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.