public interface DistributedWorkManager extends javax.resource.spi.work.DistributableWorkManager, WorkManager
Modifier and Type | Method and Description |
---|---|
DistributedWorkManagerStatistics |
getDistributedStatistics()
Get the distributed statistics
|
java.util.Collection<NotificationListener> |
getNotificationListeners()
Get the notification listeners attached
|
Policy |
getPolicy()
Get the policy
|
Selector |
getSelector()
Get the selector
|
Transport |
getTransport()
Get the transport
|
void |
initialize()
Initialize
|
boolean |
isDistributedStatisticsEnabled()
Is distributed statistics enabled
|
boolean |
isDoWorkDistributionEnabled()
Is distribution of Work instances for doWork enabled
|
boolean |
isScheduleWorkDistributionEnabled()
Is distribution of Work instances for scheduleWork enabled
|
boolean |
isStartWorkDistributionEnabled()
Is distribution of Work instances for startWork enabled
|
void |
localDoWork(javax.resource.spi.work.Work work)
doWork locally
|
void |
localScheduleWork(javax.resource.spi.work.Work work)
scheduleWork locally
|
long |
localStartWork(javax.resource.spi.work.Work work)
startWork locally
|
void |
setDistributedStatisticsEnabled(boolean v)
Set the distributed statistics enabled flag
|
void |
setDoWorkDistributionEnabled(boolean v)
Toggle distribution of Work instances for doWork
|
void |
setPolicy(Policy v)
Set the policy
|
void |
setScheduleWorkDistributionEnabled(boolean v)
Toggle distribution of Work instances for scheduleWork
|
void |
setSelector(Selector v)
Set the selector
|
void |
setStartWorkDistributionEnabled(boolean v)
Toggle distribution of Work instances for startWork
|
void |
setTransport(Transport v)
Set the transport
|
clone, getCallbackSecurity, getId, getLongRunningThreadPool, getName, getShortRunningThreadPool, getStatistics, getXATerminator, isSpecCompliant, isStatisticsEnabled, setCallbackSecurity, setId, setLongRunningThreadPool, setName, setResourceAdapter, setShortRunningThreadPool, setSpecCompliant, setStatisticsEnabled, setXATerminator
doWork, doWork, scheduleWork, scheduleWork, startWork, startWork
cancelShutdown, isShutdown, prepareShutdown, shutdown
Policy getPolicy()
void setPolicy(Policy v)
v
- The valueSelector getSelector()
void setSelector(Selector v)
v
- The valueTransport getTransport()
void setTransport(Transport v)
v
- The valueboolean isDistributedStatisticsEnabled()
void setDistributedStatisticsEnabled(boolean v)
v
- The valuejava.util.Collection<NotificationListener> getNotificationListeners()
void setDoWorkDistributionEnabled(boolean v)
v
- The valueboolean isDoWorkDistributionEnabled()
void setStartWorkDistributionEnabled(boolean v)
v
- The valueboolean isStartWorkDistributionEnabled()
void setScheduleWorkDistributionEnabled(boolean v)
v
- The valueboolean isScheduleWorkDistributionEnabled()
void localDoWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
work
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occursvoid localScheduleWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
work
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occurslong localStartWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
work
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occursDistributedWorkManagerStatistics getDistributedStatistics()
void initialize()
Copyright © 2013 IronJacamar (http://www.ironjacamar.org)