Methods
Modifier and Type |
Method and Description |
void |
addContainer(String name,
QueueContainer container) |
String |
addItemListener(String name,
ItemListener listener,
boolean includeValue,
boolean isLocal) |
void |
beforeMigration(PartitionMigrationEvent partitionMigrationEvent) |
void |
cancelEviction(String name) |
void |
clearPartitionReplica(int partitionId) |
void |
commitMigration(PartitionMigrationEvent event) |
boolean |
containsQueue(String name) |
QueueProxyImpl |
createDistributedObject(String objectId)
Creates a distributed object.
|
LocalQueueStats |
createLocalQueueStats(String name) |
LocalQueueStats |
createLocalQueueStats(String name,
int partitionId) |
TransactionalQueueProxy |
createTransactionalObject(String name,
Transaction transaction) |
void |
destroyDistributedObject(String name)
Destroys a distributed object.
|
void |
dispatchEvent(QueueEvent event,
ItemListener listener) |
LocalQueueStatsImpl |
getLocalQueueStatsImpl(String name) |
NodeEngine |
getNodeEngine() |
QueueContainer |
getOrCreateContainer(String name,
boolean fromBackup) |
Map<String,LocalQueueStats> |
getStats() |
void |
init(NodeEngine nodeEngine,
Properties properties)
Initializes this ManagedService
|
Operation |
prepareReplicationOperation(PartitionReplicationEvent event) |
boolean |
removeItemListener(String name,
String registrationId) |
void |
reset()
reset this ManagedService back to initial state.
|
void |
rollbackMigration(PartitionMigrationEvent event) |
void |
rollbackTransaction(String transactionId) |
void |
scheduleEviction(String name,
long delay) |
void |
shutdown(boolean terminate)
Shuts down this ManagedService.
|