public class DistributedWorkManagerImpl extends WorkManagerImpl implements org.jboss.jca.core.api.workmanager.DistributedWorkManager
Constructor and Description |
---|
DistributedWorkManagerImpl()
Constructor
|
Modifier and Type | Method and Description |
---|---|
org.jboss.jca.core.api.workmanager.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) |
org.jboss.jca.core.api.workmanager.DistributedWorkManagerStatistics |
getDistributedStatistics()
Get the distributed statistics
|
java.util.Collection<org.jboss.jca.core.spi.workmanager.notification.NotificationListener> |
getNotificationListeners()
Get the notification listeners attached
|
org.jboss.jca.core.spi.workmanager.policy.Policy |
getPolicy()
Get the policy
|
org.jboss.jca.core.spi.workmanager.selector.Selector |
getSelector()
Get the selector
|
org.jboss.jca.core.spi.workmanager.transport.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(org.jboss.jca.core.spi.workmanager.policy.Policy v)
Set the policy
|
void |
setScheduleWorkDistributionEnabled(boolean v)
Toggle distribution of Work instances for scheduleWork
|
void |
setSelector(org.jboss.jca.core.spi.workmanager.selector.Selector v)
Set the selector
|
void |
setStartWorkDistributionEnabled(boolean v)
Toggle distribution of Work instances for startWork
|
void |
setTransport(org.jboss.jca.core.spi.workmanager.transport.Transport v)
Set the transport
|
long |
startWork(javax.resource.spi.work.Work work) |
void |
toString(java.lang.StringBuilder sb)
Additional string representation
|
cancelShutdown, createWorkWrapper, doFirstChecks, doWork, getCallbackSecurity, getDelay, getId, getLongRunningThreadPool, getName, getResourceAdapter, getSecurityIntegration, getShortRunningThreadPool, getStatistics, getXATerminator, isShutdown, isSpecCompliant, isStatisticsEnabled, prepareShutdown, prepareShutdown, prepareShutdown, prepareShutdown, scheduleWork, setCallbackSecurity, setId, setLongRunningThreadPool, setName, setResourceAdapter, setSecurityIntegration, setShortRunningThreadPool, setSpecCompliant, setStatisticsEnabled, setXATerminator, shutdown, startWork, toString
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getCallbackSecurity, getId, getLongRunningThreadPool, getName, getSecurityIntegration, getShortRunningThreadPool, getStatistics, getXATerminator, isSpecCompliant, isStatisticsEnabled, setCallbackSecurity, setId, setLongRunningThreadPool, setName, setResourceAdapter, setSecurityIntegration, setShortRunningThreadPool, setSpecCompliant, setStatisticsEnabled, setXATerminator
public org.jboss.jca.core.spi.workmanager.policy.Policy getPolicy()
getPolicy
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
public void setPolicy(org.jboss.jca.core.spi.workmanager.policy.Policy v)
setPolicy
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
v
- The valuepublic org.jboss.jca.core.spi.workmanager.selector.Selector getSelector()
getSelector
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
public void setSelector(org.jboss.jca.core.spi.workmanager.selector.Selector v)
setSelector
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
v
- The valuepublic org.jboss.jca.core.spi.workmanager.transport.Transport getTransport()
getTransport
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
public void setTransport(org.jboss.jca.core.spi.workmanager.transport.Transport v)
setTransport
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
v
- The valuepublic boolean isDistributedStatisticsEnabled()
isDistributedStatisticsEnabled
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
public void setDistributedStatisticsEnabled(boolean v)
setDistributedStatisticsEnabled
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
v
- The valuepublic java.util.Collection<org.jboss.jca.core.spi.workmanager.notification.NotificationListener> getNotificationListeners()
getNotificationListeners
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
public void setDoWorkDistributionEnabled(boolean v)
setDoWorkDistributionEnabled
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
v
- The valuepublic boolean isDoWorkDistributionEnabled()
isDoWorkDistributionEnabled
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
public void setStartWorkDistributionEnabled(boolean v)
setStartWorkDistributionEnabled
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
v
- The valuepublic boolean isStartWorkDistributionEnabled()
isStartWorkDistributionEnabled
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
public void setScheduleWorkDistributionEnabled(boolean v)
setScheduleWorkDistributionEnabled
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
v
- The valuepublic boolean isScheduleWorkDistributionEnabled()
isScheduleWorkDistributionEnabled
in interface org.jboss.jca.core.api.workmanager.DistributedWorkManager
public void localDoWork(javax.resource.spi.work.Work work) throws javax.resource.spi.work.WorkException
localDoWork
in interface org.jboss.jca.core.api.workmanager.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 org.jboss.jca.core.api.workmanager.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 org.jboss.jca.core.api.workmanager.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 org.jboss.jca.core.api.workmanager.DistributedWorkManagerStatistics getDistributedStatistics()
getDistributedStatistics
in interface org.jboss.jca.core.api.workmanager.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 org.jboss.jca.core.api.workmanager.DistributedWorkManager
public org.jboss.jca.core.api.workmanager.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 © 2014 IronJacamar (http://www.ironjacamar.org)