|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.mx.util.JBossNotificationBroadcasterSupport org.jboss.system.ServiceMBeanSupport org.jboss.resource.work.JBossWorkManager
The work manager implementation
Field Summary |
Fields inherited from class org.jboss.system.ServiceMBeanSupport |
log, server, SERVICE_CONTROLLER_SIG, serviceName |
Fields inherited from interface javax.resource.spi.work.WorkManager |
IMMEDIATE, INDEFINITE, UNKNOWN |
Fields inherited from interface org.jboss.system.ServiceMBean |
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 wrapper)
Cancel work |
void |
doWork(javax.resource.spi.work.Work work)
|
void |
doWork(javax.resource.spi.work.Work work,
long startTimeout,
javax.resource.spi.work.ExecutionContext ctx,
javax.resource.spi.work.WorkListener listener)
|
protected void |
endWork(WorkWrapper wrapper)
End work |
protected void |
executeWork(WorkWrapper wrapper)
Execute the work |
javax.resource.spi.work.WorkManager |
getInstance()
Get the reference to this work manager |
org.jboss.util.threadpool.ThreadPool |
getThreadPool()
Retrieve the thread pool |
javax.management.ObjectName |
getThreadPoolName()
Get the thread pool name |
javax.management.ObjectName |
getXATerminatorName()
Get the XATerminator |
protected void |
importWork(WorkWrapper wrapper)
Import any work |
void |
scheduleWork(javax.resource.spi.work.Work work)
|
void |
scheduleWork(javax.resource.spi.work.Work work,
long startTimeout,
javax.resource.spi.work.ExecutionContext ctx,
javax.resource.spi.work.WorkListener listener)
|
void |
setThreadPool(org.jboss.util.threadpool.ThreadPool threadPool)
Set the thread pool |
void |
setThreadPoolName(javax.management.ObjectName threadPoolName)
Set the thread pool name |
void |
setXATerminatorName(javax.management.ObjectName xaTerminatorName)
Set the xa terminator |
protected void |
startService()
|
long |
startWork(javax.resource.spi.work.Work work)
|
long |
startWork(javax.resource.spi.work.Work work,
long startTimeout,
javax.resource.spi.work.ExecutionContext ctx,
javax.resource.spi.work.WorkListener listener)
|
protected void |
startWork(WorkWrapper wrapper)
Start work |
Methods inherited from class org.jboss.system.ServiceMBeanSupport |
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 |
addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.jboss.system.ServiceMBean |
getName, getState, getStateString, jbossInternalLifecycle |
Methods inherited from interface org.jboss.system.Service |
create, destroy, start, stop |
Constructor Detail |
public JBossWorkManager()
Method Detail |
public org.jboss.util.threadpool.ThreadPool getThreadPool()
public void setThreadPool(org.jboss.util.threadpool.ThreadPool threadPool)
threadPool
- the thread poolpublic javax.management.ObjectName getThreadPoolName()
getThreadPoolName
in interface JBossWorkManagerMBean
public void setThreadPoolName(javax.management.ObjectName threadPoolName)
setThreadPoolName
in interface JBossWorkManagerMBean
threadPoolName
- the thread pool namepublic javax.management.ObjectName getXATerminatorName()
getXATerminatorName
in interface JBossWorkManagerMBean
public void setXATerminatorName(javax.management.ObjectName xaTerminatorName)
setXATerminatorName
in interface JBossWorkManagerMBean
public javax.resource.spi.work.WorkManager getInstance()
getInstance
in interface JBossWorkManagerMBean
public void doWork(javax.resource.spi.work.Work work, long startTimeout, javax.resource.spi.work.ExecutionContext ctx, javax.resource.spi.work.WorkListener listener) 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) 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, long startTimeout, javax.resource.spi.work.ExecutionContext ctx, javax.resource.spi.work.WorkListener listener) 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) 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, long startTimeout, javax.resource.spi.work.ExecutionContext ctx, javax.resource.spi.work.WorkListener listener) 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) throws javax.resource.spi.work.WorkException
scheduleWork
in interface javax.resource.spi.work.WorkManager
javax.resource.spi.work.WorkException
protected void startService() throws Exception
Exception
protected void importWork(WorkWrapper wrapper) throws javax.resource.spi.work.WorkException
wrapper
- the work wrapper
javax.resource.spi.work.WorkException
- for any errorprotected void executeWork(WorkWrapper wrapper) throws javax.resource.spi.work.WorkException
wrapper
- the work wrapper
javax.resource.spi.work.WorkException
- for any errorprotected void startWork(WorkWrapper wrapper) throws javax.resource.spi.work.WorkException
wrapper
- the work wrapper
javax.resource.spi.work.WorkException
- for any errorprotected void endWork(WorkWrapper wrapper)
wrapper
- the work wrapper
javax.resource.spi.work.WorkException
- for any errorprotected void cancelWork(WorkWrapper wrapper)
wrapper
- the work wrapper
javax.resource.spi.work.WorkException
- for any error
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |