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, 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	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	handle(Collection<Map.Entry<Address,List<Integer>>> collection, int partitionStateVersion)
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()

handle

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

Specified by:

handle 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