public class DistributedWorkManagerImpl extends WorkManagerImpl implements DistributedWorkManager
Constructor and Description |
---|
DistributedWorkManagerImpl()
Constructor
|
Modifier and Type | Method and Description |
---|---|
WorkManager |
clone()
Clone the WorkManager implementation
|
protected void |
deltaDoWorkAccepted()
Delta doWork accepted
|
protected void |
deltaDoWorkRejected()
Delta doWork rejected
|
protected void |
deltaScheduleWorkAccepted()
Delta scheduleWork accepted
|
protected void |
deltaScheduleWorkRejected()
Delta scheduleWork rejected
|
protected void |
deltaStartWorkAccepted()
Delta startWork accepted
|
protected void |
deltaStartWorkRejected()
Delta startWork rejected
|
protected void |
deltaWorkFailed()
Delta work failed
|
protected void |
deltaWorkSuccessful()
Delta work successful
|
void |
doWork(javax.resource.spi.work.Work work) |
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 |
scheduleWork(javax.resource.spi.work.Work work) |
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
|
long |
startWork(javax.resource.spi.work.Work work) |
void |
toString(java.lang.StringBuilder sb)
Additional string representation
|
cancelShutdown, doFirstChecks, doWork, getCallbackSecurity, getId, getLongRunningThreadPool, getName, getResourceAdapter, getShortRunningThreadPool, getStatistics, getXATerminator, isShutdown, isSpecCompliant, isStatisticsEnabled, prepareShutdown, scheduleWork, setCallbackSecurity, setId, setLongRunningThreadPool, setName, setResourceAdapter, setShortRunningThreadPool, setSpecCompliant, setStatisticsEnabled, setXATerminator, shutdown, startWork, toString
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getCallbackSecurity, getId, getLongRunningThreadPool, getName, getShortRunningThreadPool, getStatistics, getXATerminator, isSpecCompliant, isStatisticsEnabled, setCallbackSecurity, setId, setLongRunningThreadPool, setName, setResourceAdapter, setShortRunningThreadPool, setSpecCompliant, setStatisticsEnabled, setXATerminator
doWork, scheduleWork, startWork
cancelShutdown, isShutdown, prepareShutdown, shutdown
public Policy getPolicy()
getPolicy
in interface DistributedWorkManager
public void setPolicy(Policy v)
setPolicy
in interface DistributedWorkManager
v
- The valuepublic Selector getSelector()
getSelector
in interface DistributedWorkManager
public void setSelector(Selector v)
setSelector
in interface DistributedWorkManager
v
- The valuepublic Transport getTransport()
getTransport
in interface DistributedWorkManager
public void setTransport(Transport v)
setTransport
in interface DistributedWorkManager
v
- The valuepublic boolean isDistributedStatisticsEnabled()
isDistributedStatisticsEnabled
in interface DistributedWorkManager
public void setDistributedStatisticsEnabled(boolean v)
setDistributedStatisticsEnabled
in interface DistributedWorkManager
v
- The valuepublic java.util.Collection<NotificationListener> getNotificationListeners()
getNotificationListeners
in interface DistributedWorkManager
public void setDoWorkDistributionEnabled(boolean v)
setDoWorkDistributionEnabled
in interface DistributedWorkManager
v
- The valuepublic boolean isDoWorkDistributionEnabled()
isDoWorkDistributionEnabled
in interface DistributedWorkManager
public void setStartWorkDistributionEnabled(boolean v)
setStartWorkDistributionEnabled
in interface DistributedWorkManager
v
- The valuepublic boolean isStartWorkDistributionEnabled()
isStartWorkDistributionEnabled
in interface DistributedWorkManager
public void setScheduleWorkDistributionEnabled(boolean v)
setScheduleWorkDistributionEnabled
in interface DistributedWorkManager
v
- The valuepublic boolean isScheduleWorkDistributionEnabled()
isScheduleWorkDistributionEnabled
in interface DistributedWorkManager
public void localDoWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
localDoWork
in interface DistributedWorkManager
work
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occurspublic void localScheduleWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
localScheduleWork
in interface DistributedWorkManager
work
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occurspublic long localStartWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
localStartWork
in interface DistributedWorkManager
work
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occurspublic void doWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
doWork
in interface javax.resource.spi.work.WorkManager
doWork
in class WorkManagerImpl
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
startWork
in class WorkManagerImpl
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
scheduleWork
in class WorkManagerImpl
javax.resource.spi.work.WorkException
public DistributedWorkManagerStatistics getDistributedStatistics()
getDistributedStatistics
in interface DistributedWorkManager
protected void deltaDoWorkAccepted()
deltaDoWorkAccepted
in class WorkManagerImpl
protected void deltaDoWorkRejected()
deltaDoWorkRejected
in class WorkManagerImpl
protected void deltaStartWorkAccepted()
deltaStartWorkAccepted
in class WorkManagerImpl
protected void deltaStartWorkRejected()
deltaStartWorkRejected
in class WorkManagerImpl
protected void deltaScheduleWorkAccepted()
deltaScheduleWorkAccepted
in class WorkManagerImpl
protected void deltaScheduleWorkRejected()
deltaScheduleWorkRejected
in class WorkManagerImpl
protected void deltaWorkSuccessful()
deltaWorkSuccessful
in class WorkManagerImpl
protected void deltaWorkFailed()
deltaWorkFailed
in class WorkManagerImpl
public void initialize()
initialize
in interface DistributedWorkManager
public WorkManager clone() throws java.lang.CloneNotSupportedException
clone
in class WorkManagerImpl
java.lang.CloneNotSupportedException
- Thrown if the copy operation isn't supportedpublic void toString(java.lang.StringBuilder sb)
toString
in class WorkManagerImpl
sb
- The string builderCopyright © 2013 IronJacamar (http://www.ironjacamar.org)