com.hazelcast.client.spi.impl

Class ClientPartitionServiceImpl

java.lang.Object

com.hazelcast.client.impl.protocol.codec.ClientAddPartitionListenerCodec.AbstractEventHandler

com.hazelcast.client.spi.impl.ClientPartitionServiceImpl

All Implemented Interfaces:

ClientPartitionService, ClusterSwitchAwareService, EventHandler<ClientMessage>

public final class ClientPartitionServiceImpl
extends com.hazelcast.client.impl.protocol.codec.ClientAddPartitionListenerCodec.AbstractEventHandler
implements EventHandler<ClientMessage>, ClientPartitionService

The ClientPartitionService implementation.

Constructor Summary

Constructors

Constructor and Description
ClientPartitionServiceImpl(HazelcastClientInstanceImpl client)

Method Summary

Modifier and Type	Method and Description
void	beforeClusterSwitch(CandidateClusterContext context)
void	beforeListenerRegister() This method is called before registration request is sent to node.
Partition	getPartition(int partitionId)
int	getPartitionCount()
int	getPartitionId(Data key)
int	getPartitionId(Object key)
Address	getPartitionOwner(int partitionId)
void	handlePartitionsEventV15(Collection<Map.Entry<Address,List<Integer>>> collection, int partitionStateVersion)
boolean	isPartitionCountConsistent(int partitionCount)
void	listenPartitionTable(Connection ownerConnection)
void	onListenerRegister() This method is called when registration request response is successfully returned from node.
void	refreshPartitions()
void	start()
void	stop()

Methods inherited from class com.hazelcast.client.impl.protocol.codec.ClientAddPartitionListenerCodec.AbstractEventHandler

handle

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.hazelcast.client.spi.EventHandler

handle

Constructor Detail

ClientPartitionServiceImpl

public ClientPartitionServiceImpl(HazelcastClientInstanceImpl client)

Method Detail

start

public void start()

listenPartitionTable

public void listenPartitionTable(Connection ownerConnection)
                          throws Exception

Throws:

Exception

refreshPartitions

public void refreshPartitions()

handlePartitionsEventV15

public void handlePartitionsEventV15(Collection<Map.Entry<Address,List<Integer>>> collection,
                                     int partitionStateVersion)

Specified by:

handlePartitionsEventV15 in class com.hazelcast.client.impl.protocol.codec.ClientAddPartitionListenerCodec.AbstractEventHandler

beforeListenerRegister

public void beforeListenerRegister()

Description copied from interface: EventHandler

This method is called before registration request is sent to node. Note that this method will also be called while first registered node is dead and re-registering to a second node.

Specified by:

beforeListenerRegister in interface EventHandler<ClientMessage>

onListenerRegister

public void onListenerRegister()

Description copied from interface: EventHandler

This method is called when registration request response is successfully returned from node. Note that this method will also be called while first registered node is dead and re-registering to a second node.

Specified by:

onListenerRegister in interface EventHandler<ClientMessage>

stop

public void stop()

getPartitionOwner

public Address getPartitionOwner(int partitionId)

Specified by:

getPartitionOwner in interface ClientPartitionService

getPartitionId

public int getPartitionId(Data key)

Specified by:

getPartitionId in interface ClientPartitionService

getPartitionId

public int getPartitionId(Object key)

Specified by:

getPartitionId in interface ClientPartitionService

getPartitionCount

public int getPartitionCount()

Specified by:

getPartitionCount in interface ClientPartitionService

getPartition

public Partition getPartition(int partitionId)

Specified by:

getPartition in interface ClientPartitionService

isPartitionCountConsistent

public boolean isPartitionCountConsistent(int partitionCount)

Specified by:

isPartitionCountConsistent in interface ClientPartitionService

Parameters:

partitionCount - new partition count

Returns:

true if partitions are not checked yet or last partition count is equal to the partition count provided, otherwise return false

beforeClusterSwitch

public void beforeClusterSwitch(CandidateClusterContext context)

Specified by:

beforeClusterSwitch in interface ClusterSwitchAwareService