com.hazelcast.client.impl

Class ClientEndpointImpl

java.lang.Object

com.hazelcast.client.impl.ClientEndpointImpl

All Implemented Interfaces:

ClientEndpoint, Client, Endpoint

public final class ClientEndpointImpl
extends Object
implements ClientEndpoint

The ClientEndpoint and Client implementation.

Constructor Summary

Constructors

Constructor and Description
ClientEndpointImpl(ClientEngineImpl clientEngine, Connection conn)

Method Summary

Methods

Modifier and Type	Method and Description
void	addDestroyAction(String registrationId, Callable<Boolean> removeAction) Adds a remove callable to be called when endpoint is destroyed Note: removeDestroyAction should be called when there is no need to destroy action anymore.
void	addListenerDestroyAction(String service, String topic, String id) Adds a remove callable to be called when endpoint is destroyed to clean related listener Following line will be called when endpoint destroyed : eventService.deregisterListener(service, topic, id); Note: removeDestroyAction should be called when there is no need to destroy action anymore.
void	authenticated(ClientPrincipal principal)
void	authenticated(ClientPrincipal principal, Credentials credentials, boolean firstConnection)
void	clearAllListeners()
void	destroy()
ClientType	getClientType() Returns the type of this client.
Connection	getConnection()
Credentials	getCredentials()
ClientPrincipal	getPrincipal()
InetSocketAddress	getSocketAddress() Returns the socket address of this client.
Subject	getSubject()
TransactionContext	getTransactionContext(String txnId)
String	getUuid() Returns a unique uuid for this client.
boolean	isAlive() Checks if the endpoint is alive.
boolean	isAuthenticated()
boolean	isFirstConnection()
boolean	removeDestroyAction(String id)
void	removeTransactionContext(String txnId)
void	sendClientMessage(ClientMessage clientMessage)
void	sendEvent(Object key, Object event, long callId)
void	sendResponse(Object response, long callId)
void	setLoginContext(LoginContext loginContext)
void	setTransactionContext(TransactionContext transactionContext)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientEndpointImpl

public ClientEndpointImpl(ClientEngineImpl clientEngine,
                  Connection conn)

Method Detail

getConnection

public Connection getConnection()

Specified by:

getConnection in interface ClientEndpoint

getUuid

public String getUuid()

Description copied from interface: Client

Returns a unique uuid for this client.

Specified by:

getUuid in interface Client

Specified by:

getUuid in interface Endpoint

Returns:

a unique uuid for this client

isAlive

public boolean isAlive()

Description copied from interface: ClientEndpoint

Checks if the endpoint is alive.

Specified by:

isAlive in interface ClientEndpoint

Returns:

true if alive, false otherwise.

setLoginContext

public void setLoginContext(LoginContext loginContext)

Specified by:

setLoginContext in interface ClientEndpoint

getSubject

public Subject getSubject()

Specified by:

getSubject in interface ClientEndpoint

isFirstConnection

public boolean isFirstConnection()

Specified by:

isFirstConnection in interface ClientEndpoint

authenticated

public void authenticated(ClientPrincipal principal,
                 Credentials credentials,
                 boolean firstConnection)

Specified by:

authenticated in interface ClientEndpoint

authenticated

public void authenticated(ClientPrincipal principal)

Specified by:

authenticated in interface ClientEndpoint

isAuthenticated

public boolean isAuthenticated()

Specified by:

isAuthenticated in interface ClientEndpoint

Returns:

true if endpoint is authenticated with valid security credentials, returns false otherwise

getPrincipal

public ClientPrincipal getPrincipal()

Specified by:

getPrincipal in interface ClientEndpoint

getSocketAddress

public InetSocketAddress getSocketAddress()

Description copied from interface: Client

Returns the socket address of this client.

Specified by:

getSocketAddress in interface Client

Specified by:

getSocketAddress in interface Endpoint

Returns:

the socket address of this client

getClientType

public ClientType getClientType()

Description copied from interface: Client

Returns the type of this client.

Specified by:

getClientType in interface Client

Returns:

the type of this client

getTransactionContext

public TransactionContext getTransactionContext(String txnId)

Specified by:

getTransactionContext in interface ClientEndpoint

getCredentials

public Credentials getCredentials()

Specified by:

getCredentials in interface ClientEndpoint

setTransactionContext

public void setTransactionContext(TransactionContext transactionContext)

Specified by:

setTransactionContext in interface ClientEndpoint

removeTransactionContext

public void removeTransactionContext(String txnId)

Specified by:

removeTransactionContext in interface ClientEndpoint

addListenerDestroyAction

public void addListenerDestroyAction(String service,
                            String topic,
                            String id)

Description copied from interface: ClientEndpoint

Adds a remove callable to be called when endpoint is destroyed to clean related listener Following line will be called when endpoint destroyed : eventService.deregisterListener(service, topic, id); Note: removeDestroyAction should be called when there is no need to destroy action anymore.

Specified by:

addListenerDestroyAction in interface ClientEndpoint

Parameters:

service - name of the related service of listener

topic - topic name of listener(mostly distributed object name)

id - registration id of remove action

addDestroyAction

public void addDestroyAction(String registrationId,
                    Callable<Boolean> removeAction)

Description copied from interface: ClientEndpoint

Adds a remove callable to be called when endpoint is destroyed Note: removeDestroyAction should be called when there is no need to destroy action anymore.

Specified by:

addDestroyAction in interface ClientEndpoint

Parameters:

registrationId - registration id of destroy action

removeAction - callable that will be called when endpoint is destroyed

removeDestroyAction

public boolean removeDestroyAction(String id)

Specified by:

removeDestroyAction in interface ClientEndpoint

Parameters:

id - registration id of destroy action

Returns:

true if remove is successful

clearAllListeners

public void clearAllListeners()

Specified by:

clearAllListeners in interface ClientEndpoint

destroy

public void destroy()
             throws LoginException

Throws:

LoginException

sendResponse

public void sendResponse(Object response,
                long callId)

Specified by:

sendResponse in interface ClientEndpoint

sendClientMessage

public void sendClientMessage(ClientMessage clientMessage)

sendEvent

public void sendEvent(Object key,
             Object event,
             long callId)

Specified by:

sendEvent in interface ClientEndpoint

toString

public String toString()

Overrides:

toString in class Object