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.
|
Modifier and Type | Method and Description |
---|---|
static Address |
Address.fromMap(Map<String,String> map)
create an instance from a Map
|
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
|
Copyright © 2021 JBoss by Red Hat. All rights reserved.