public interface Transport
Modifier and Type | Method and Description |
---|---|
void |
clearDistributedStatistics(Address address)
Clear distributed statistics
|
void |
deltaDoWorkAccepted(Address address)
Delta doWork accepted
|
void |
deltaDoWorkRejected(Address address)
Delta doWork rejected
|
void |
deltaScheduleWorkAccepted(Address address)
Delta scheduleWork accepted
|
void |
deltaScheduleWorkRejected(Address address)
Delta scheduleWork rejected
|
void |
deltaStartWorkAccepted(Address address)
Delta startWork accepted
|
void |
deltaStartWorkRejected(Address address)
Delta startWork rejected
|
void |
deltaWorkFailed(Address address)
Delta work failed
|
void |
deltaWorkSuccessful(Address address)
Delta work successful
|
void |
doWork(Address address,
javax.resource.spi.work.DistributableWork work)
doWork
|
DistributedWorkManagerStatisticsValues |
getDistributedStatistics(Address address)
Get the distributed statistics
|
java.lang.String |
getId()
Get the identifier of the transport
|
long |
getLongRunningFree(Address address)
Get The number of free thread in long running pool from a distributed work manager
|
long |
getShortRunningFree(Address address)
Get The number of free thread in short running pool from a distributed work manager
|
void |
initialize()
Initialize the transport
|
boolean |
isInitialized()
Is the transport initialized
|
long |
ping(Address address)
Ping time to a distributed work manager
|
void |
register(Address address)
Register
|
void |
scheduleWork(Address address,
javax.resource.spi.work.DistributableWork work)
scheduleWork
|
void |
shutdown()
Shutdown the transport
|
void |
startup()
Startup the transport
|
long |
startWork(Address address,
javax.resource.spi.work.DistributableWork work)
startWork
|
void |
unregister(Address address)
Unregister
|
void |
updateLongRunningFree(Address address,
long freeCount)
Update The number of free thread in long running pool from a distributed work manager
|
void |
updateShortRunningFree(Address address,
long freeCount)
Update The number of free thread in short running pool from a distributed work manager
|
java.lang.String getId()
void startup() throws java.lang.Throwable
java.lang.Throwable
- In case of an errorvoid shutdown() throws java.lang.Throwable
java.lang.Throwable
- In case of an errorvoid initialize() throws java.lang.Throwable
java.lang.Throwable
- In case of an errorboolean isInitialized()
void register(Address address)
address
- The addressvoid unregister(Address address)
address
- The addresslong ping(Address address)
address
- The addresslong getShortRunningFree(Address address)
address
- The addresslong getLongRunningFree(Address address)
address
- The addressvoid updateShortRunningFree(Address address, long freeCount)
address
- The addressfreeCount
- the number of freeThreadvoid updateLongRunningFree(Address address, long freeCount)
address
- The addressfreeCount
- the number of freeThreadDistributedWorkManagerStatisticsValues getDistributedStatistics(Address address)
address
- The addressvoid clearDistributedStatistics(Address address)
address
- The addressvoid deltaDoWorkAccepted(Address address)
address
- The addressvoid deltaDoWorkRejected(Address address)
address
- The addressvoid deltaStartWorkAccepted(Address address)
address
- The addressvoid deltaStartWorkRejected(Address address)
address
- The addressvoid deltaScheduleWorkAccepted(Address address)
address
- The addressvoid deltaScheduleWorkRejected(Address address)
address
- The addressvoid deltaWorkSuccessful(Address address)
address
- The addressvoid deltaWorkFailed(Address address)
address
- The addressvoid doWork(Address address, javax.resource.spi.work.DistributableWork work) throws javax.resource.spi.work.WorkException
address
- The addresswork
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occursvoid scheduleWork(Address address, javax.resource.spi.work.DistributableWork work) throws javax.resource.spi.work.WorkException
address
- The addresswork
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occurslong startWork(Address address, javax.resource.spi.work.DistributableWork work) throws javax.resource.spi.work.WorkException
address
- The addresswork
- The workjavax.resource.spi.work.WorkException
- Thrown if an error occursCopyright © 2013 IronJacamar (http://www.ironjacamar.org)