public final class ClientEndpointImpl extends Object implements ClientEndpoint
ClientEndpoint
and Client
implementation.Constructor and Description |
---|
ClientEndpointImpl(ClientEngine clientEngine,
NodeEngineImpl nodeEngine,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
addDestroyAction(UUID 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,
UUID 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(UUID clientUuid,
Credentials credentials,
String clientVersion,
long authCorrelationId,
String clientName,
Set<String> labels) |
void |
clearAllListeners() |
void |
destroy() |
String |
getClientStatistics() |
ClientType |
getClientType()
Returns the type of this client.
|
Connection |
getConnection() |
Credentials |
getCredentials() |
Set<String> |
getLabels() |
String |
getName()
This method may return null depending on the client version and the client type
Java client provides client name starting with 3.12
|
InetSocketAddress |
getSocketAddress()
Returns the socket address of this client.
|
Subject |
getSubject() |
TransactionContext |
getTransactionContext(UUID txnId) |
UUID |
getUuid()
Returns a unique UUID for this client.
|
boolean |
isAlive()
Checks if the endpoint is alive.
|
boolean |
isAuthenticated() |
boolean |
removeDestroyAction(UUID id) |
void |
removeTransactionContext(UUID txnId) |
void |
setClientStatistics(String stats)
Updates to the latest client statistics.
|
void |
setClientVersion(String version) |
void |
setLoginContext(LoginContext loginContext) |
void |
setTransactionContext(TransactionContext transactionContext) |
String |
toString() |
public ClientEndpointImpl(ClientEngine clientEngine, NodeEngineImpl nodeEngine, Connection connection)
public Connection getConnection()
getConnection
in interface ClientEndpoint
public UUID getUuid()
Client
public boolean isAlive()
ClientEndpoint
isAlive
in interface ClientEndpoint
public void setLoginContext(LoginContext loginContext)
setLoginContext
in interface ClientEndpoint
public Subject getSubject()
getSubject
in interface ClientEndpoint
public void authenticated(UUID clientUuid, Credentials credentials, String clientVersion, long authCorrelationId, String clientName, Set<String> labels)
authenticated
in interface ClientEndpoint
public boolean isAuthenticated()
isAuthenticated
in interface ClientEndpoint
public void setClientVersion(String version)
setClientVersion
in interface ClientEndpoint
version
- the version string as obtained from the environmentpublic void setClientStatistics(String stats)
ClientEndpoint
setClientStatistics
in interface ClientEndpoint
stats
- the latest statistics retrieved from the clientpublic String getClientStatistics()
getClientStatistics
in interface ClientEndpoint
public InetSocketAddress getSocketAddress()
Client
getSocketAddress
in interface Client
getSocketAddress
in interface Endpoint
public ClientType getClientType()
Client
getClientType
in interface Client
public String getName()
Client
public TransactionContext getTransactionContext(UUID txnId)
getTransactionContext
in interface ClientEndpoint
public Credentials getCredentials()
getCredentials
in interface ClientEndpoint
public void setTransactionContext(TransactionContext transactionContext)
setTransactionContext
in interface ClientEndpoint
public void removeTransactionContext(UUID txnId)
removeTransactionContext
in interface ClientEndpoint
public void addListenerDestroyAction(String service, String topic, UUID id)
ClientEndpoint
addListenerDestroyAction
in interface ClientEndpoint
service
- name of the related service of listenertopic
- topic name of listener(mostly distributed object name)id
- registration ID of remove actionpublic void addDestroyAction(UUID registrationId, Callable<Boolean> removeAction)
ClientEndpoint
addDestroyAction
in interface ClientEndpoint
registrationId
- registration ID of destroy actionremoveAction
- callable that will be called when endpoint is destroyedpublic boolean removeDestroyAction(UUID id)
removeDestroyAction
in interface ClientEndpoint
id
- registration ID of destroy actionpublic void clearAllListeners()
clearAllListeners
in interface ClientEndpoint
public void destroy() throws LoginException
LoginException
Copyright © 2019 Hazelcast, Inc.. All rights reserved.