Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.ra
Class ActiveMQBaseEndpointWorker  view ActiveMQBaseEndpointWorker download ActiveMQBaseEndpointWorker.java

java.lang.Object
  extended byorg.activemq.ra.ActiveMQBaseEndpointWorker
Direct Known Subclasses:
ActiveMQAsfEndpointWorker, ActiveMQPollingEndpointWorker

public abstract class ActiveMQBaseEndpointWorker
extends java.lang.Object

Version:
$Revision: 1.1.1.1 $ $Date: 2005/03/11 21:15:09 $

Field Summary
protected  ActiveMQResourceAdapter adapter
           
protected  ActiveMQEndpointActivationKey endpointActivationKey
           
protected  javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory
           
private static org.apache.commons.logging.Log log
           
static java.lang.reflect.Method ON_MESSAGE_METHOD
           
protected  boolean transacted
           
protected  javax.resource.spi.work.WorkManager workManager
           
 
Constructor Summary
ActiveMQBaseEndpointWorker(ActiveMQResourceAdapter adapter, ActiveMQEndpointActivationKey key)
           
 
Method Summary
static void safeClose(javax.jms.Connection c)
           
static void safeClose(javax.jms.ConnectionConsumer cc)
           
static void safeClose(javax.jms.Session s)
           
abstract  void start()
           
abstract  void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

private static final org.apache.commons.logging.Log log

ON_MESSAGE_METHOD

public static final java.lang.reflect.Method ON_MESSAGE_METHOD

adapter

protected ActiveMQResourceAdapter adapter

endpointActivationKey

protected ActiveMQEndpointActivationKey endpointActivationKey

endpointFactory

protected javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory

workManager

protected javax.resource.spi.work.WorkManager workManager

transacted

protected boolean transacted
Constructor Detail

ActiveMQBaseEndpointWorker

public ActiveMQBaseEndpointWorker(ActiveMQResourceAdapter adapter,
                                  ActiveMQEndpointActivationKey key)
                           throws javax.resource.ResourceException
Method Detail

safeClose

public static void safeClose(javax.jms.Session s)

safeClose

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

safeClose

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

start

public abstract void start()
                    throws javax.resource.spi.work.WorkException,
                           javax.resource.ResourceException

stop

public abstract void stop()
                   throws java.lang.InterruptedException