com.hazelcast.client.impl

Class ClientEndpointManagerImpl

java.lang.Object

com.hazelcast.client.impl.ClientEndpointManagerImpl

All Implemented Interfaces:

ClientEndpointManager

public class ClientEndpointManagerImpl
extends Object
implements ClientEndpointManager

Manages and stores ClientEndpointImpls.

Constructor Summary

Constructors

Constructor and Description
ClientEndpointManagerImpl(ClientEngineImpl clientEngine, NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all endpoints.
Connection	findLiveConnectionFor(String clientUuid)
ClientEndpoint	getEndpoint(Connection connection) Gets the endpoint for a given connection.
Collection<ClientEndpoint>	getEndpoints() Returns the current endpoints.
Set<ClientEndpoint>	getEndpoints(String clientUuid) Gets all the endpoints for a given client.
void	registerEndpoint(ClientEndpoint endpoint) Registers an endpoint with this ClientEndpointManager.
void	removeEndpoint(ClientEndpoint clientEndpoint, boolean closeImmediately, String reason) Removes an endpoint and optionally closes it immediately.
void	removeEndpoint(ClientEndpoint endpoint, String reason) Removes an endpoint from this ClientEndpointManager.
void	removeEndpoints(String memberUuid)
int	size() Returns the current number of endpoints.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientEndpointManagerImpl

public ClientEndpointManagerImpl(ClientEngineImpl clientEngine,
                                 NodeEngine nodeEngine)

Method Detail

getEndpoints

public Set<ClientEndpoint> getEndpoints(String clientUuid)

Description copied from interface: ClientEndpointManager

Gets all the endpoints for a given client.

Specified by:

getEndpoints in interface ClientEndpointManager

Parameters:

clientUuid - the uuid of the client

Returns:

a set of all the endpoints for the client. If no endpoints are found, an empty set is returned.

getEndpoint

public ClientEndpoint getEndpoint(Connection connection)

Description copied from interface: ClientEndpointManager

Gets the endpoint for a given connection.

Specified by:

getEndpoint in interface ClientEndpointManager

Parameters:

connection - the connection to the endpoint.

Returns:

the found endpoint or null of no endpoint was found.

registerEndpoint

public void registerEndpoint(ClientEndpoint endpoint)

Description copied from interface: ClientEndpointManager

Registers an endpoint with this ClientEndpointManager. If the endpoint already is registered, the call is ignored.

Specified by:

registerEndpoint in interface ClientEndpointManager

Parameters:

endpoint - the endpoint to register.

removeEndpoint

public void removeEndpoint(ClientEndpoint endpoint,
                           String reason)

Description copied from interface: ClientEndpointManager

Removes an endpoint from this ClientEndpointManager. This method doesn't close the endpoint. todo: what happens when the endpoint already is removed todo: what happens when the endpoint was never registered

Specified by:

removeEndpoint in interface ClientEndpointManager

Parameters:

endpoint - the endpoint to remove.

reason - The reason why the endpoint is being removed

See Also:

ClientEndpointManager.removeEndpoint(ClientEndpoint, boolean, String)

removeEndpoint

public void removeEndpoint(ClientEndpoint clientEndpoint,
                           boolean closeImmediately,
                           String reason)

Description copied from interface: ClientEndpointManager

Removes an endpoint and optionally closes it immediately. todo: what happens when the endpoint already is removed todo: what happens when the endpoint was never registered

Specified by:

removeEndpoint in interface ClientEndpointManager

Parameters:

clientEndpoint - the endpoint to remove.

closeImmediately - if the endpoint is immediately closed.

reason - The reason why the endpoint is being removed.

See Also:

ClientEndpointManager.removeEndpoint(ClientEndpoint, String)

removeEndpoints

public void removeEndpoints(String memberUuid)

clear

public void clear()

Description copied from interface: ClientEndpointManager

Removes all endpoints. Nothing is done on the endpoints themselves; they are just removed from this ClientEndpointManager. Can safely be called when there are no endpoints.

Specified by:

clear in interface ClientEndpointManager

getEndpoints

public Collection<ClientEndpoint> getEndpoints()

Description copied from interface: ClientEndpointManager

Returns the current endpoints.

Specified by:

getEndpoints in interface ClientEndpointManager

Returns:

the endpoints.

size

public int size()

Description copied from interface: ClientEndpointManager

Returns the current number of endpoints.

Specified by:

size in interface ClientEndpointManager

Returns:

the current number of endpoints.

findLiveConnectionFor

public Connection findLiveConnectionFor(String clientUuid)

Specified by:

findLiveConnectionFor in interface ClientEndpointManager

Parameters:

clientUuid - The uuid of the desired client conection

Returns:

Any connection with the provided client uuid which is live