Methods
Modifier and Type |
Method and Description |
String |
addListener(String name,
EventListener listener,
Data key,
boolean includeValue,
boolean local) |
void |
beforeMigration(PartitionMigrationEvent partitionMigrationEvent) |
void |
clearPartitionReplica(int partitionId) |
void |
commitMigration(PartitionMigrationEvent event) |
DistributedObject |
createDistributedObject(String name)
Creates a distributed object.
|
LocalMultiMapStats |
createStats(String name) |
<T extends TransactionalObject> T |
createTransactionalObject(String name,
Transaction transaction) |
void |
destroyDistributedObject(String name)
Destroys a distributed object.
|
void |
dispatchEvent(EventData event,
EntryListener listener) |
LocalMultiMapStatsImpl |
getLocalMultiMapStatsImpl(String name) |
NodeEngine |
getNodeEngine() |
MultiMapContainer |
getOrCreateCollectionContainer(int partitionId,
String name) |
MultiMapPartitionContainer |
getPartitionContainer(int partitionId) |
SerializationService |
getSerializationService() |
Map<String,LocalMultiMapStats> |
getStats() |
void |
init(NodeEngine nodeEngine,
Properties properties)
Initializes this ManagedService
|
void |
insertMigratedData(int partitionId,
Map<String,Map> map) |
Set<Data> |
localKeySet(String name) |
Operation |
prepareReplicationOperation(PartitionReplicationEvent event) |
void |
publishEntryEvent(String multiMapName,
EntryEventType eventType,
Data key,
Object newValue,
Object oldValue) |
void |
publishMultiMapEvent(String mapName,
EntryEventType eventType,
int numberOfEntriesAffected) |
boolean |
removeListener(String name,
String registrationId) |
void |
reset()
reset this ManagedService back to initial state.
|
void |
rollbackMigration(PartitionMigrationEvent event) |
void |
rollbackTransaction(String transactionId) |
void |
shutdown(boolean terminate)
Shuts down this ManagedService.
|