public class WorkManagerImpl extends java.lang.Object implements WorkManager
Constructor and Description |
---|
WorkManagerImpl()
Constructor - by default the WorkManager is running in spec-compliant mode
|
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) |
public WorkManagerImpl()
public org.jboss.threads.BlockingExecutor getShortRunningThreadPool()
public void setShortRunningThreadPool(org.jboss.threads.BlockingExecutor executor)
executor
- The executorpublic org.jboss.threads.BlockingExecutor getLongRunningThreadPool()
public void setLongRunningThreadPool(org.jboss.threads.BlockingExecutor executor)
executor
- The executorpublic XATerminator getXATerminator()
public void setXATerminator(XATerminator xaTerminator)
xaTerminator
- The XA terminatorpublic boolean isSpecCompliant()
public void setSpecCompliant(boolean v)
v
- The valuepublic Callback getCallbackSecurity()
public void setCallbackSecurity(Callback v)
v
- The valuepublic WorkManager clone() throws java.lang.CloneNotSupportedException
clone
in class java.lang.Object
java.lang.CloneNotSupportedException
- Thrown if the copy operation isn't supportedpublic void doWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
doWork
in interface javax.resource.spi.work.WorkManager
javax.resource.spi.work.WorkException
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
doWork
in interface javax.resource.spi.work.WorkManager
javax.resource.spi.work.WorkException
public long startWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
startWork
in interface javax.resource.spi.work.WorkManager
javax.resource.spi.work.WorkException
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
startWork
in interface javax.resource.spi.work.WorkManager
javax.resource.spi.work.WorkException
public void scheduleWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
scheduleWork
in interface javax.resource.spi.work.WorkManager
javax.resource.spi.work.WorkException
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
scheduleWork
in interface javax.resource.spi.work.WorkManager
javax.resource.spi.work.WorkException
public void prepareShutdown()
prepareShutdown
in interface GracefulShutdown
public void shutdown()
shutdown
in interface GracefulShutdown
public boolean isShutdown()
isShutdown
in interface GracefulShutdown
Copyright ? 2008-2009 Red Hat Middleware LLC (http://www.jboss.com/)