|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.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 JBossWorkManagerMBeanpublic void setThreadPoolName(javax.management.ObjectName threadPoolName)
setThreadPoolName in interface JBossWorkManagerMBeanthreadPoolName - the thread pool namepublic javax.management.ObjectName getXATerminatorName()
getXATerminatorName in interface JBossWorkManagerMBeanpublic void setXATerminatorName(javax.management.ObjectName xaTerminatorName)
setXATerminatorName in interface JBossWorkManagerMBeanpublic 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.WorkManagerjavax.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.WorkManagerjavax.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.WorkManagerjavax.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.WorkManagerjavax.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.WorkManagerjavax.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.WorkManagerjavax.resource.spi.work.WorkException
protected void startService()
throws Exception
Exceptionprotected 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 | ||||||||||