T
- the typepublic abstract class AbstractRemoteTransport<T>
extends java.lang.Object
implements org.jboss.jca.core.spi.workmanager.transport.Transport
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.ExecutorService |
executorService
The kernel executorService
|
protected java.util.Map<org.jboss.jca.core.spi.workmanager.Address,T> |
nodes
The nodes
|
Constructor and Description |
---|
AbstractRemoteTransport()
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
clearDistributedStatistics(org.jboss.jca.core.spi.workmanager.Address address)
Clear distributed statistics
|
void |
deltaDoWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
Delta doWork accepted
|
void |
deltaDoWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
Delta doWork rejected
|
void |
deltaScheduleWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
Delta scheduleWork accepted
|
void |
deltaScheduleWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
Delta scheduleWork rejected
|
void |
deltaStartWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
Delta startWork accepted
|
void |
deltaStartWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
Delta startWork rejected
|
void |
deltaWorkFailed(org.jboss.jca.core.spi.workmanager.Address address)
Delta work failed
|
void |
deltaWorkSuccessful(org.jboss.jca.core.spi.workmanager.Address address)
Delta work successful
|
void |
doWork(org.jboss.jca.core.spi.workmanager.Address address,
javax.resource.spi.work.DistributableWork work)
doWork
|
java.util.Set<org.jboss.jca.core.spi.workmanager.Address> |
getAddresses(T physicalAddress)
Get the addresses
|
org.jboss.jca.core.api.workmanager.DistributedWorkManagerStatisticsValues |
getDistributedStatistics(org.jboss.jca.core.spi.workmanager.Address address)
Get the distributed statistics
|
java.util.concurrent.ExecutorService |
getExecutorService()
Get the executorService.
|
java.lang.String |
getId()
Get the identifier of the transport
|
long |
getLongRunningFree(org.jboss.jca.core.spi.workmanager.Address address)
Get The number of free thread in long running pool from a distributed work manager
|
protected abstract T |
getOwnAddress()
Get the own address
|
long |
getShortRunningFree(org.jboss.jca.core.spi.workmanager.Address address)
Get The number of free thread in short running pool from a distributed work manager
|
void |
join(org.jboss.jca.core.spi.workmanager.Address logicalAddress,
T physicalAddress)
join
|
void |
leave(T physicalAddress)
leave
|
void |
localClearDistributedStatistics(org.jboss.jca.core.spi.workmanager.Address logicalAddress)
localClearDistributedStatistics
|
void |
localDeltaDoWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
Local delta doWork accepted
|
void |
localDeltaDoWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
Local delta doWork rejected
|
void |
localDeltaScheduleWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
Local delta scheduleWork accepted
|
void |
localDeltaScheduleWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
Local delta scheduleWork rejected
|
void |
localDeltaStartWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
Local delta startWork accepted
|
void |
localDeltaStartWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
Local delta startWork rejected
|
void |
localDeltaWorkFailed(org.jboss.jca.core.spi.workmanager.Address address)
Local delta work failed
|
void |
localDeltaWorkSuccessful(org.jboss.jca.core.spi.workmanager.Address address)
Local delta work successful
|
void |
localDoWork(org.jboss.jca.core.spi.workmanager.Address address,
javax.resource.spi.work.DistributableWork work)
localDoWork
|
org.jboss.jca.core.api.workmanager.DistributedWorkManagerStatisticsValues |
localGetDistributedStatistics(org.jboss.jca.core.spi.workmanager.Address address)
localGetDistributedStatistics
|
long |
localGetLongRunningFree(org.jboss.jca.core.spi.workmanager.Address address)
localGetLongRunningFree
|
long |
localGetShortRunningFree(org.jboss.jca.core.spi.workmanager.Address address)
localGetShortRunningFree
|
long |
localPing()
localPing
|
void |
localScheduleWork(org.jboss.jca.core.spi.workmanager.Address address,
javax.resource.spi.work.DistributableWork work)
localScheduleWork
|
long |
localStartWork(org.jboss.jca.core.spi.workmanager.Address address,
javax.resource.spi.work.DistributableWork work)
localStartWork
|
void |
localUpdateLongRunningFree(org.jboss.jca.core.spi.workmanager.Address logicalAddress,
java.lang.Long freeCount)
localUpdateLongRunningFree
|
void |
localUpdateShortRunningFree(org.jboss.jca.core.spi.workmanager.Address logicalAddress,
java.lang.Long freeCount)
localUpdateShortRunningFree
|
void |
localWorkManagerAdd(org.jboss.jca.core.spi.workmanager.Address address,
T physicalAddress)
localWorkManagerAdd
|
void |
localWorkManagerRemove(org.jboss.jca.core.spi.workmanager.Address address)
localWorkManagerRemove
|
long |
ping(org.jboss.jca.core.spi.workmanager.Address address)
Ping time to a distributed work manager
|
void |
register(org.jboss.jca.core.spi.workmanager.Address address)
Register
|
void |
scheduleWork(org.jboss.jca.core.spi.workmanager.Address address,
javax.resource.spi.work.DistributableWork work)
scheduleWork
|
protected abstract java.io.Serializable |
sendMessage(T physicalAddress,
ProtocolMessages.Request request,
java.io.Serializable... parameters)
send a messagge using specific protocol.
|
void |
setExecutorService(java.util.concurrent.ExecutorService executorService)
Set the executorService.
|
void |
setId(java.lang.String id)
Set the identifier
|
long |
startWork(org.jboss.jca.core.spi.workmanager.Address address,
javax.resource.spi.work.DistributableWork work)
startWork
|
void |
unregister(org.jboss.jca.core.spi.workmanager.Address address)
Unregister
|
void |
updateLongRunningFree(org.jboss.jca.core.spi.workmanager.Address address,
long freeCount)
Update The number of free thread in long running pool from a distributed work manager
|
void |
updateShortRunningFree(org.jboss.jca.core.spi.workmanager.Address address,
long freeCount)
Update The number of free thread in short running pool from a distributed work manager
|
protected java.util.concurrent.ExecutorService executorService
protected java.util.Map<org.jboss.jca.core.spi.workmanager.Address,T> nodes
public java.lang.String getId()
getId
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
public void setId(java.lang.String id)
id
- The valuepublic long ping(org.jboss.jca.core.spi.workmanager.Address address)
ping
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic long getShortRunningFree(org.jboss.jca.core.spi.workmanager.Address address)
org.jboss.jca.core.spi.workmanager.transport.Transport
getShortRunningFree
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic long getLongRunningFree(org.jboss.jca.core.spi.workmanager.Address address)
org.jboss.jca.core.spi.workmanager.transport.Transport
getLongRunningFree
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void updateShortRunningFree(org.jboss.jca.core.spi.workmanager.Address address, long freeCount)
org.jboss.jca.core.spi.workmanager.transport.Transport
updateShortRunningFree
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addressfreeCount
- the number of freeThreadpublic void updateLongRunningFree(org.jboss.jca.core.spi.workmanager.Address address, long freeCount)
org.jboss.jca.core.spi.workmanager.transport.Transport
updateLongRunningFree
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addressfreeCount
- the number of freeThreadpublic org.jboss.jca.core.api.workmanager.DistributedWorkManagerStatisticsValues getDistributedStatistics(org.jboss.jca.core.spi.workmanager.Address address)
getDistributedStatistics
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void clearDistributedStatistics(org.jboss.jca.core.spi.workmanager.Address address)
clearDistributedStatistics
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void deltaDoWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
deltaDoWorkAccepted
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void deltaDoWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
deltaDoWorkRejected
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void deltaStartWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
deltaStartWorkAccepted
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void deltaStartWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
deltaStartWorkRejected
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void deltaScheduleWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
deltaScheduleWorkAccepted
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void deltaScheduleWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
deltaScheduleWorkRejected
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void deltaWorkSuccessful(org.jboss.jca.core.spi.workmanager.Address address)
deltaWorkSuccessful
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void deltaWorkFailed(org.jboss.jca.core.spi.workmanager.Address address)
deltaWorkFailed
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void doWork(org.jboss.jca.core.spi.workmanager.Address address, javax.resource.spi.work.DistributableWork work) throws javax.resource.spi.work.WorkException
doWork
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresswork
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occurspublic void scheduleWork(org.jboss.jca.core.spi.workmanager.Address address, javax.resource.spi.work.DistributableWork work) throws javax.resource.spi.work.WorkException
scheduleWork
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresswork
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occurspublic long startWork(org.jboss.jca.core.spi.workmanager.Address address, javax.resource.spi.work.DistributableWork work) throws javax.resource.spi.work.WorkException
startWork
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresswork
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occurspublic java.util.concurrent.ExecutorService getExecutorService()
public void setExecutorService(java.util.concurrent.ExecutorService executorService)
executorService
- The executorService to set.public void register(org.jboss.jca.core.spi.workmanager.Address address)
register
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic void unregister(org.jboss.jca.core.spi.workmanager.Address address)
unregister
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
address
- The addresspublic java.util.Set<org.jboss.jca.core.spi.workmanager.Address> getAddresses(T physicalAddress)
physicalAddress
- the physical addresspublic void join(org.jboss.jca.core.spi.workmanager.Address logicalAddress, T physicalAddress)
logicalAddress
- the logical addressphysicalAddress
- the physical addresspublic void leave(T physicalAddress)
physicalAddress
- the physical addresspublic long localPing()
public void localWorkManagerAdd(org.jboss.jca.core.spi.workmanager.Address address, T physicalAddress)
address
- the logical addressphysicalAddress
- the physical addresspublic void localWorkManagerRemove(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localDoWork(org.jboss.jca.core.spi.workmanager.Address address, javax.resource.spi.work.DistributableWork work) throws javax.resource.spi.work.WorkException
address
- the logical addresswork
- the workjavax.resource.spi.work.WorkException
- in case of errorpublic long localStartWork(org.jboss.jca.core.spi.workmanager.Address address, javax.resource.spi.work.DistributableWork work) throws javax.resource.spi.work.WorkException
address
- the logical addresswork
- the workjavax.resource.spi.work.WorkException
- in case of errorpublic void localScheduleWork(org.jboss.jca.core.spi.workmanager.Address address, javax.resource.spi.work.DistributableWork work) throws javax.resource.spi.work.WorkException
address
- the logical addresswork
- the workjavax.resource.spi.work.WorkException
- in case of errorpublic long localGetShortRunningFree(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic long localGetLongRunningFree(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localUpdateShortRunningFree(org.jboss.jca.core.spi.workmanager.Address logicalAddress, java.lang.Long freeCount)
logicalAddress
- the logical addressfreeCount
- the free countpublic void localUpdateLongRunningFree(org.jboss.jca.core.spi.workmanager.Address logicalAddress, java.lang.Long freeCount)
logicalAddress
- the logical addressfreeCount
- the free countpublic org.jboss.jca.core.api.workmanager.DistributedWorkManagerStatisticsValues localGetDistributedStatistics(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localClearDistributedStatistics(org.jboss.jca.core.spi.workmanager.Address logicalAddress)
logicalAddress
- the logical addresspublic void localDeltaDoWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localDeltaDoWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localDeltaStartWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localDeltaStartWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localDeltaScheduleWorkAccepted(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localDeltaScheduleWorkRejected(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localDeltaWorkSuccessful(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addresspublic void localDeltaWorkFailed(org.jboss.jca.core.spi.workmanager.Address address)
address
- the logical addressprotected abstract T getOwnAddress()
protected abstract java.io.Serializable sendMessage(T physicalAddress, ProtocolMessages.Request request, java.io.Serializable... parameters) throws javax.resource.spi.work.WorkException
physicalAddress
- the physical addressrequest
- the requestparameters
- the parametersjavax.resource.spi.work.WorkException
- in case of problem with the workCopyright © 2014 IronJacamar (http://www.ironjacamar.org)