|
||||||||||
PREV CLASS NEXT CLASS (src) | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.mx.util.JBossNotificationBroadcasterSupport (src)
org.jboss.system.ServiceMBeanSupport (src)
org.jboss.resource.work.JBossWorkManager
The work manager implementation
Field Summary |
Fields inherited from class org.jboss.system.ServiceMBeanSupport (src) |
log, server, SERVICE_CONTROLLER_SIG, serviceName |
Fields inherited from interface javax.resource.spi.work.WorkManager (src) |
IMMEDIATE, INDEFINITE, UNKNOWN |
Fields inherited from interface org.jboss.system.ServiceMBean (src) |
CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED |
Constructor Summary | |
JBossWorkManager()
|
Method Summary | |
protected void |
cancelWork(WorkWrapper (src) wrapper)
Cancel work |
void |
doWork(Work (src) work)
Executes the work, the call blocks until the work completes |
void |
doWork(Work (src) work,
long startTimeout,
ExecutionContext (src) ctx,
WorkListener (src) listener)
Executes the work, the call blocks until the work completes |
protected void |
endWork(WorkWrapper (src) wrapper)
End work |
protected void |
executeWork(WorkWrapper (src) wrapper)
Execute the work |
WorkManager (src) |
getInstance()
Get the reference to this work manager |
ThreadPool (src) |
getThreadPool()
Retrieve the thread pool |
ObjectName (src) |
getThreadPoolName()
Get the thread pool name |
ObjectName (src) |
getXATerminatorName()
Get the XATerminator |
protected void |
importWork(WorkWrapper (src) wrapper)
Import any work |
void |
scheduleWork(Work (src) work)
Executes the work, the call returns immediatley |
void |
scheduleWork(Work (src) work,
long startTimeout,
ExecutionContext (src) ctx,
WorkListener (src) listener)
Executes the work, the call returns immediately |
void |
setThreadPool(ThreadPool (src) threadPool)
Set the thread pool |
void |
setThreadPoolName(ObjectName (src) threadPoolName)
Set the thread pool name |
void |
setXATerminatorName(ObjectName (src) xaTerminatorName)
Set the xa terminator |
protected void |
startService()
Sub-classes should override this method to provide custum 'start' logic. |
long |
startWork(Work (src) work)
Executes the work, the call blocks until the work starts |
long |
startWork(Work (src) work,
long startTimeout,
ExecutionContext (src) ctx,
WorkListener (src) listener)
Executes the work, the call blocks until the work starts |
protected void |
startWork(WorkWrapper (src) wrapper)
Start work |
Methods inherited from class org.jboss.system.ServiceMBeanSupport (src) |
create, createService, destroy, destroyService, getLog, getName, getNextNotificationSequenceNumber, getObjectName, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, postDeregister, postRegister, preDeregister, preRegister, start, stop, stopService |
Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport (src) |
addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public JBossWorkManager()
Method Detail |
public ThreadPool (src) getThreadPool()
public void setThreadPool(ThreadPool (src) threadPool)
threadPool
- the thread poolpublic ObjectName (src) getThreadPoolName()
public void setThreadPoolName(ObjectName (src) threadPoolName)
threadPoolName
- the thread pool namepublic ObjectName (src) getXATerminatorName()
public void setXATerminatorName(ObjectName (src) xaTerminatorName)
public WorkManager (src) getInstance()
public void doWork(Work (src) work, long startTimeout, ExecutionContext (src) ctx, WorkListener (src) listener) throws WorkException (src)
WorkManager (src)
doWork
in interface WorkManager (src)
work
- the workstartTimeout
- the wait before executionctx
- the execution contextlistener
- the work listener
WorkException (src)
- a generic errorpublic void doWork(Work (src) work) throws WorkException (src)
WorkManager (src)
doWork
in interface WorkManager (src)
work
- the work
WorkException (src)
- a generic errorpublic long startWork(Work (src) work, long startTimeout, ExecutionContext (src) ctx, WorkListener (src) listener) throws WorkException (src)
WorkManager (src)
startWork
in interface WorkManager (src)
work
- the workstartTimeout
- the wait before executionctx
- the execution contextlistener
- the work listener
WorkException (src)
- a generic errorpublic long startWork(Work (src) work) throws WorkException (src)
WorkManager (src)
startWork
in interface WorkManager (src)
work
- the work
WorkException (src)
- a generic errorpublic void scheduleWork(Work (src) work, long startTimeout, ExecutionContext (src) ctx, WorkListener (src) listener) throws WorkException (src)
WorkManager (src)
scheduleWork
in interface WorkManager (src)
work
- the workstartTimeout
- the wait before executionctx
- the execution contextlistener
- the work listener
WorkException (src)
- a generic errorpublic void scheduleWork(Work (src) work) throws WorkException (src)
WorkManager (src)
scheduleWork
in interface WorkManager (src)
work
- the work
WorkException (src)
- a generic errorprotected void startService() throws java.lang.Exception
ServiceMBeanSupport (src)
This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.
startService
in class ServiceMBeanSupport (src)
java.lang.Exception
protected void importWork(WorkWrapper (src) wrapper) throws WorkException (src)
wrapper
- the work wrapper
WorkException (src)
- for any errorprotected void executeWork(WorkWrapper (src) wrapper) throws WorkException (src)
wrapper
- the work wrapper
WorkException (src)
- for any errorprotected void startWork(WorkWrapper (src) wrapper) throws WorkException (src)
wrapper
- the work wrapper
WorkException (src)
- for any errorprotected void endWork(WorkWrapper (src) wrapper)
wrapper
- the work wrapper
WorkException (src)
- for any errorprotected void cancelWork(WorkWrapper (src) wrapper)
wrapper
- the work wrapper
WorkException (src)
- for any error
|
||||||||||
PREV CLASS NEXT CLASS (src) | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |