org.jboss.jca.core.workmanager

Class WorkManagerImpl

java.lang.Object

org.jboss.jca.core.workmanager.WorkManagerImpl

All Implemented Interfaces:

java.lang.Cloneable, javax.resource.spi.work.WorkManager, GracefulShutdown

public class WorkManagerImpl
extends java.lang.Object
implements WorkManager

The work manager implementation.

Author:

Jesper Pedersen

Field Summary

Fields inherited from interface javax.resource.spi.work.WorkManager

IMMEDIATE, INDEFINITE, UNKNOWN

Constructor Summary

Constructors

Constructor and Description
WorkManagerImpl() Constructor - by default the WorkManager is running in spec-compliant mode

Method Summary

Methods

Modifier and Type	Method and Description
WorkManager	clone() Clone the WorkManager implementation
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)
Callback	getCallbackSecurity() Get the callback security module
org.jboss.threads.BlockingExecutor	getLongRunningThreadPool() Retrieve the executor for long running tasks
org.jboss.threads.BlockingExecutor	getShortRunningThreadPool() Retrieve the executor for short running tasks
XATerminator	getXATerminator() Get the XATerminator
boolean	isShutdown() Is the component shutdown
boolean	isSpecCompliant() Is spec compliant
void	prepareShutdown() Signal the component to prepare for shutdown
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)
void	setCallbackSecurity(Callback v) Set callback security module
void	setLongRunningThreadPool(org.jboss.threads.BlockingExecutor executor) Set the executor for long running tasks
void	setShortRunningThreadPool(org.jboss.threads.BlockingExecutor executor) Set the executor for short running tasks
void	setSpecCompliant(boolean v) Set spec compliant flag
void	setXATerminator(XATerminator xaTerminator) Set the XATerminator
void	shutdown() Shutdown the component
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

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkManagerImpl

public WorkManagerImpl()

Constructor - by default the WorkManager is running in spec-compliant mode

Method Detail

getShortRunningThreadPool

public org.jboss.threads.BlockingExecutor getShortRunningThreadPool()

Retrieve the executor for short running tasks

Returns:

The executor

setShortRunningThreadPool

public void setShortRunningThreadPool(org.jboss.threads.BlockingExecutor executor)

Set the executor for short running tasks

Parameters:

executor - The executor

getLongRunningThreadPool

public org.jboss.threads.BlockingExecutor getLongRunningThreadPool()

Retrieve the executor for long running tasks

Returns:

The executor

setLongRunningThreadPool

public void setLongRunningThreadPool(org.jboss.threads.BlockingExecutor executor)

Set the executor for long running tasks

Parameters:

executor - The executor

getXATerminator

public XATerminator getXATerminator()

Get the XATerminator

Returns:

The XA terminator

setXATerminator

public void setXATerminator(XATerminator xaTerminator)

Set the XATerminator

Parameters:

xaTerminator - The XA terminator

isSpecCompliant

public boolean isSpecCompliant()

Is spec compliant

Returns:

True if spec compliant; otherwise false

setSpecCompliant

public void setSpecCompliant(boolean v)

Set spec compliant flag

Parameters:

v - The value

getCallbackSecurity

public Callback getCallbackSecurity()

Get the callback security module

Returns:

The value

setCallbackSecurity

public void setCallbackSecurity(Callback v)

Set callback security module

Parameters:

v - The value

clone

public WorkManager clone()
                  throws java.lang.CloneNotSupportedException

Clone the WorkManager implementation

Overrides:

clone in class java.lang.Object

Returns:

A copy of the implementation

Throws:

java.lang.CloneNotSupportedException - Thrown if the copy operation isn't supported

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

prepareShutdown

public void prepareShutdown()

Signal the component to prepare for shutdown

Specified by:

prepareShutdown in interface GracefulShutdown

shutdown

public void shutdown()

Shutdown the component

Specified by:

shutdown in interface GracefulShutdown

isShutdown

public boolean isShutdown()

Is the component shutdown

Specified by:

isShutdown in interface GracefulShutdown

Returns:

True if shutdown; false if active