public class ClientPartitionListenerService extends Object
Modifier and Type | Method and Description |
---|---|
void |
deregisterPartitionListener(ClientEndpoint clientEndpoint) |
Map<ClientEndpoint,Long> |
getPartitionListeningEndpoints() |
Collection<Map.Entry<Address,List<Integer>>> |
getPartitions(PartitionTableView partitionTableView)
If any partition does not have an owner, this method returns empty collection
|
void |
onPartitionStateChange() |
void |
registerPartitionListener(ClientEndpoint clientEndpoint,
long correlationId) |
public void onPartitionStateChange()
public void registerPartitionListener(ClientEndpoint clientEndpoint, long correlationId)
public void deregisterPartitionListener(ClientEndpoint clientEndpoint)
public Collection<Map.Entry<Address,List<Integer>>> getPartitions(PartitionTableView partitionTableView)
partitionTableView
- will be converted to address->partitions mappingpublic Map<ClientEndpoint,Long> getPartitionListeningEndpoints()
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.