org.apache.geronimo.connector.work
Class GeronimoWorkManager

java.lang.Object
  extended byorg.apache.geronimo.connector.work.GeronimoWorkManager
All Implemented Interfaces:
javax.resource.spi.work.WorkManager
Direct Known Subclasses:
GeronimoWorkManagerGBean

public class GeronimoWorkManager
extends Object
implements javax.resource.spi.work.WorkManager

WorkManager implementation which uses under the cover three WorkExecutorPool - one for each synchronization policy - in order to dispatch the submitted Work instances.

A WorkManager is a component of the JCA specifications, which allows a Resource Adapter to submit tasks to an Application Server for execution.

Version:
$Rev: 392847 $ $Date: 2006-04-10 00:58:39 +0200 (Mon, 10 Apr 2006) $

Field Summary
 
Fields inherited from interface javax.resource.spi.work.WorkManager
IMMEDIATE, INDEFINITE, UNKNOWN
 
Constructor Summary
GeronimoWorkManager()
          Create a WorkManager.
GeronimoWorkManager(org.apache.geronimo.pool.GeronimoExecutor sync, org.apache.geronimo.pool.GeronimoExecutor start, org.apache.geronimo.pool.GeronimoExecutor sched, org.apache.geronimo.transaction.context.TransactionContextManager transactionContextManager)
           
 
Method Summary
 void doFail()
           
 void doStart()
           
 void doStop()
           
 void doWork(javax.resource.spi.work.Work work)
           
 void doWork(javax.resource.spi.work.Work work, long startTimeout, javax.resource.spi.work.ExecutionContext execContext, javax.resource.spi.work.WorkListener workListener)
           
 org.apache.geronimo.pool.GeronimoExecutor getScheduledWorkExecutorPool()
           
 org.apache.geronimo.pool.GeronimoExecutor getStartWorkExecutorPool()
           
 org.apache.geronimo.pool.GeronimoExecutor getSyncWorkExecutorPool()
           
 javax.resource.spi.XATerminator getXATerminator()
           
 void scheduleWork(javax.resource.spi.work.Work work)
           
 void scheduleWork(javax.resource.spi.work.Work work, long startTimeout, javax.resource.spi.work.ExecutionContext execContext, javax.resource.spi.work.WorkListener workListener)
           
 long startWork(javax.resource.spi.work.Work work)
           
 long startWork(javax.resource.spi.work.Work work, long startTimeout, javax.resource.spi.work.ExecutionContext execContext, javax.resource.spi.work.WorkListener workListener)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

GeronimoWorkManager

public GeronimoWorkManager()
Create a WorkManager.


GeronimoWorkManager

public GeronimoWorkManager(org.apache.geronimo.pool.GeronimoExecutor sync,
                           org.apache.geronimo.pool.GeronimoExecutor start,
                           org.apache.geronimo.pool.GeronimoExecutor sched,
                           org.apache.geronimo.transaction.context.TransactionContextManager transactionContextManager)
Method Detail

doStart

public void doStart()
             throws Exception
Throws:
Exception

doStop

public void doStop()
            throws Exception
Throws:
Exception

doFail

public void doFail()

getXATerminator

public javax.resource.spi.XATerminator getXATerminator()

getSyncWorkExecutorPool

public org.apache.geronimo.pool.GeronimoExecutor getSyncWorkExecutorPool()

getStartWorkExecutorPool

public org.apache.geronimo.pool.GeronimoExecutor getStartWorkExecutorPool()

getScheduledWorkExecutorPool

public org.apache.geronimo.pool.GeronimoExecutor getScheduledWorkExecutorPool()

doWork

public void doWork(javax.resource.spi.work.Work work)
            throws javax.resource.spi.work.WorkException
Specified by:
doWork in interface javax.resource.spi.work.WorkManager
Throws:
javax.resource.spi.work.WorkException

doWork

public void doWork(javax.resource.spi.work.Work work,
                   long startTimeout,
                   javax.resource.spi.work.ExecutionContext execContext,
                   javax.resource.spi.work.WorkListener workListener)
            throws javax.resource.spi.work.WorkException
Specified by:
doWork in interface javax.resource.spi.work.WorkManager
Throws:
javax.resource.spi.work.WorkException

startWork

public long startWork(javax.resource.spi.work.Work work)
               throws javax.resource.spi.work.WorkException
Specified by:
startWork in interface javax.resource.spi.work.WorkManager
Throws:
javax.resource.spi.work.WorkException

startWork

public long startWork(javax.resource.spi.work.Work work,
                      long startTimeout,
                      javax.resource.spi.work.ExecutionContext execContext,
                      javax.resource.spi.work.WorkListener workListener)
               throws javax.resource.spi.work.WorkException
Specified by:
startWork in interface javax.resource.spi.work.WorkManager
Throws:
javax.resource.spi.work.WorkException

scheduleWork

public void scheduleWork(javax.resource.spi.work.Work work)
                  throws javax.resource.spi.work.WorkException
Specified by:
scheduleWork in interface javax.resource.spi.work.WorkManager
Throws:
javax.resource.spi.work.WorkException

scheduleWork

public void scheduleWork(javax.resource.spi.work.Work work,
                         long startTimeout,
                         javax.resource.spi.work.ExecutionContext execContext,
                         javax.resource.spi.work.WorkListener workListener)
                  throws javax.resource.spi.work.WorkException
Specified by:
scheduleWork in interface javax.resource.spi.work.WorkManager
Throws:
javax.resource.spi.work.WorkException


Copyright © 2003-2007 Apache Software Foundation. All Rights Reserved.