Package | Description |
---|---|
org.jboss.jca.core.spi.workmanager |
This package contains the SPI for the IronJacamar WorkManager
|
org.jboss.jca.core.spi.workmanager.notification |
This package contains interfaces around notifications
|
org.jboss.jca.core.spi.workmanager.selector |
This package contains the SPI for the selector for the distributed work manager.
|
org.jboss.jca.core.spi.workmanager.transport |
This package contains the SPI for the transport for the distributed work manager.
|
org.jboss.jca.core.workmanager |
This package contains the WorkManager implementation.
|
org.jboss.jca.core.workmanager.notification |
This package contains implementations for the notification listener functionality.
|
org.jboss.jca.core.workmanager.selector |
This package contains the selectors for the distributed work manager
|
org.jboss.jca.core.workmanager.transport.remote |
This package contains the protocol common classes for remote transports (socket and jgroups)
|
org.jboss.jca.core.workmanager.transport.remote.jgroups |
This package contains the jgroups transport
|
Modifier and Type | Method and Description |
---|---|
int |
Address.compareTo(Address a) |
Modifier and Type | Method and Description |
---|---|
void |
NotificationListener.join(Address address)
A distributed work manager joined
|
void |
NotificationListener.leave(Address address)
A distributed work manager left
|
void |
NotificationListener.updateLongRunningFree(Address address,
long free)
Update the long thread pool information for a distributed work manager
|
void |
NotificationListener.updateShortRunningFree(Address address,
long free)
Update the short thread pool information for a distributed work manager
|
Modifier and Type | Method and Description |
---|---|
Address |
Selector.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Modifier and Type | Method and Description |
---|---|
Address |
Selector.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Modifier and Type | Method and Description |
---|---|
void |
Transport.clearDistributedStatistics(Address address)
Clear distributed statistics
|
void |
Transport.deltaDoWorkAccepted(Address address)
Delta doWork accepted
|
void |
Transport.deltaDoWorkRejected(Address address)
Delta doWork rejected
|
void |
Transport.deltaScheduleWorkAccepted(Address address)
Delta scheduleWork accepted
|
void |
Transport.deltaScheduleWorkRejected(Address address)
Delta scheduleWork rejected
|
void |
Transport.deltaStartWorkAccepted(Address address)
Delta startWork accepted
|
void |
Transport.deltaStartWorkRejected(Address address)
Delta startWork rejected
|
void |
Transport.deltaWorkFailed(Address address)
Delta work failed
|
void |
Transport.deltaWorkSuccessful(Address address)
Delta work successful
|
void |
Transport.doWork(Address address,
javax.resource.spi.work.DistributableWork work)
doWork
|
DistributedWorkManagerStatisticsValues |
Transport.getDistributedStatistics(Address address)
Get the distributed statistics
|
long |
Transport.getLongRunningFree(Address address)
Get The number of free thread in long running pool from a distributed work manager
|
long |
Transport.getShortRunningFree(Address address)
Get The number of free thread in short running pool from a distributed work manager
|
long |
Transport.ping(Address address)
Ping time to a distributed work manager
|
void |
Transport.register(Address address)
Register
|
void |
Transport.scheduleWork(Address address,
javax.resource.spi.work.DistributableWork work)
scheduleWork
|
long |
Transport.startWork(Address address,
javax.resource.spi.work.DistributableWork work)
startWork
|
void |
Transport.unregister(Address address)
Unregister
|
void |
Transport.updateLongRunningFree(Address address,
long freeCount)
Update The number of free thread in long running pool from a distributed work manager
|
void |
Transport.updateShortRunningFree(Address address,
long freeCount)
Update The number of free thread in short running pool from a distributed work manager
|
Modifier and Type | Method and Description |
---|---|
Address |
WorkManagerEvent.getAddress()
Get the address
|
Modifier and Type | Method and Description |
---|---|
void |
DistributedWorkManagerStatisticsImpl.join(Address address)
A distributed work manager joined
|
void |
DistributedWorkManagerStatisticsImpl.leave(Address address)
A distributed work manager left
|
DistributedWorkManager |
WorkManagerCoordinator.resolveDistributedWorkManager(Address address)
Resolve a distributed work manager
|
WorkManager |
WorkManagerCoordinator.resolveWorkManager(Address address)
Resolve a work manager
|
void |
DistributedWorkManagerStatisticsImpl.setOwnId(Address v)
Set own id
|
void |
DistributedWorkManagerStatisticsImpl.updateLongRunningFree(Address address,
long free)
Update the long thread pool information for a distributed work manager
|
void |
DistributedWorkManagerStatisticsImpl.updateShortRunningFree(Address address,
long free)
Update the short thread pool information for a distributed work manager
|
Constructor and Description |
---|
DistributedWorkManagerStatisticsImpl(Address ownId,
Transport t)
Constructor
|
WorkEventListener(boolean isLong,
StatisticsExecutor shortThreadPool,
StatisticsExecutor longThreadPool,
Address address,
Transport transport)
Constructor
|
WorkManagerEvent(int type,
Address address)
Constructor
|
WorkManagerEvent(int type,
Address address,
long value)
Constructor
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.String,java.util.Map<Address,java.lang.Long>> |
AbstractNotificationListener.longRunning
Long running
|
protected java.util.Map<java.lang.String,java.util.Map<Address,java.lang.Long>> |
AbstractNotificationListener.shortRunning
Short running
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractNotificationListener.join(Address address)
A distributed work manager joined
|
void |
AbstractNotificationListener.leave(Address address)
A distributed work manager left
|
void |
AbstractNotificationListener.updateLongRunningFree(Address address,
long free)
Update the long thread pool information for a distributed work manager
|
void |
AbstractNotificationListener.updateShortRunningFree(Address address,
long free)
Update the short thread pool information for a distributed work manager
|
Modifier and Type | Method and Description |
---|---|
abstract Address |
AbstractSelector.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Address |
FirstAvailable.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Address |
MaxFreeThreads.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Address |
PingTime.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<Address,java.lang.Long> |
AbstractSelector.getSelectionMap(java.lang.String wmId,
javax.resource.spi.work.DistributableWork work)
Get explicit work manager override
|
Modifier and Type | Method and Description |
---|---|
abstract Address |
AbstractSelector.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Address |
FirstAvailable.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Address |
MaxFreeThreads.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Address |
PingTime.selectDistributedWorkManager(Address own,
javax.resource.spi.work.DistributableWork work)
Select a distributed work manager
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<Address,T> |
AbstractRemoteTransport.nodes
The nodes
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<Address> |
AbstractRemoteTransport.getAddresses(T physicalAddress)
Get the addresses
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractRemoteTransport.clearDistributedStatistics(Address address)
Clear distributed statistics
|
void |
AbstractRemoteTransport.deltaDoWorkAccepted(Address address)
Delta doWork accepted
|
void |
AbstractRemoteTransport.deltaDoWorkRejected(Address address)
Delta doWork rejected
|
void |
AbstractRemoteTransport.deltaScheduleWorkAccepted(Address address)
Delta scheduleWork accepted
|
void |
AbstractRemoteTransport.deltaScheduleWorkRejected(Address address)
Delta scheduleWork rejected
|
void |
AbstractRemoteTransport.deltaStartWorkAccepted(Address address)
Delta startWork accepted
|
void |
AbstractRemoteTransport.deltaStartWorkRejected(Address address)
Delta startWork rejected
|
void |
AbstractRemoteTransport.deltaWorkFailed(Address address)
Delta work failed
|
void |
AbstractRemoteTransport.deltaWorkSuccessful(Address address)
Delta work successful
|
void |
AbstractRemoteTransport.doWork(Address address,
javax.resource.spi.work.DistributableWork work)
doWork
|
DistributedWorkManagerStatisticsValues |
AbstractRemoteTransport.getDistributedStatistics(Address address)
Get the distributed statistics
|
long |
AbstractRemoteTransport.getLongRunningFree(Address address) |
long |
AbstractRemoteTransport.getShortRunningFree(Address address) |
void |
AbstractRemoteTransport.join(Address logicalAddress,
T physicalAddress)
join
|
void |
AbstractRemoteTransport.localClearDistributedStatistics(Address logicalAddress)
localClearDistributedStatistics
|
void |
AbstractRemoteTransport.localDeltaDoWorkAccepted(Address address)
Local delta doWork accepted
|
void |
AbstractRemoteTransport.localDeltaDoWorkRejected(Address address)
Local delta doWork rejected
|
void |
AbstractRemoteTransport.localDeltaScheduleWorkAccepted(Address address)
Local delta scheduleWork accepted
|
void |
AbstractRemoteTransport.localDeltaScheduleWorkRejected(Address address)
Local delta scheduleWork rejected
|
void |
AbstractRemoteTransport.localDeltaStartWorkAccepted(Address address)
Local delta startWork accepted
|
void |
AbstractRemoteTransport.localDeltaStartWorkRejected(Address address)
Local delta startWork rejected
|
void |
AbstractRemoteTransport.localDeltaWorkFailed(Address address)
Local delta work failed
|
void |
AbstractRemoteTransport.localDeltaWorkSuccessful(Address address)
Local delta work successful
|
void |
AbstractRemoteTransport.localDoWork(Address address,
javax.resource.spi.work.DistributableWork work)
localDoWork
|
DistributedWorkManagerStatisticsValues |
AbstractRemoteTransport.localGetDistributedStatistics(Address address)
localGetDistributedStatistics
|
long |
AbstractRemoteTransport.localGetLongRunningFree(Address address)
localGetLongRunningFree
|
long |
AbstractRemoteTransport.localGetShortRunningFree(Address address)
localGetShortRunningFree
|
void |
AbstractRemoteTransport.localScheduleWork(Address address,
javax.resource.spi.work.DistributableWork work)
localScheduleWork
|
long |
AbstractRemoteTransport.localStartWork(Address address,
javax.resource.spi.work.DistributableWork work)
localStartWork
|
void |
AbstractRemoteTransport.localUpdateLongRunningFree(Address logicalAddress,
java.lang.Long freeCount)
localUpdateLongRunningFree
|
void |
AbstractRemoteTransport.localUpdateShortRunningFree(Address logicalAddress,
java.lang.Long freeCount)
localUpdateShortRunningFree
|
void |
AbstractRemoteTransport.localWorkManagerAdd(Address address,
T physicalAddress)
localWorkManagerAdd
|
void |
AbstractRemoteTransport.localWorkManagerRemove(Address address)
localWorkManagerRemove
|
long |
AbstractRemoteTransport.ping(Address address)
Ping time to a distributed work manager
|
void |
AbstractRemoteTransport.register(Address address)
Register
|
void |
AbstractRemoteTransport.scheduleWork(Address address,
javax.resource.spi.work.DistributableWork work)
scheduleWork
|
long |
AbstractRemoteTransport.startWork(Address address,
javax.resource.spi.work.DistributableWork work)
startWork
|
void |
AbstractRemoteTransport.unregister(Address address)
Unregister
|
void |
AbstractRemoteTransport.updateLongRunningFree(Address address,
long freeCount) |
void |
AbstractRemoteTransport.updateShortRunningFree(Address address,
long freeCount) |
Modifier and Type | Method and Description |
---|---|
java.util.Set<Address> |
JGroupsTransport.getWorkManagers()
Get WorkManagers
|
Modifier and Type | Method and Description |
---|---|
void |
JGroupsTransport.addWorkManager(Address logicalAddress,
org.jgroups.Address address)
Delegator
|
void |
JGroupsTransport.executeDoWork(Address logicalAddress,
ClassBundle classBundle,
byte[] b)
Execute doWork
|
void |
JGroupsTransport.executeScheduleWork(Address logicalAddress,
ClassBundle classBundle,
byte[] b)
Execute scheduleWork
|
long |
JGroupsTransport.executeStartWork(Address logicalAddress,
ClassBundle classBundle,
byte[] b)
Execute startWork
|
void |
JGroupsTransport.join(Address logicalAddress,
org.jgroups.Address address)
Delegator
|
Copyright © 2013 IronJacamar (http://www.ironjacamar.org)