public class ClientSmartListenerService extends ClientListenerServiceImpl implements ConnectionListener, ConnectionHeartbeatListener
client, logger, registrationExecutor, serializationService
Constructor and Description |
---|
ClientSmartListenerService(HazelcastClientInstanceImpl client,
int eventThreadCount,
int eventQueueCapacity) |
Modifier and Type | Method and Description |
---|---|
void |
connectionAdded(Connection connection) |
void |
connectionRemoved(Connection connection) |
boolean |
deregisterListener(String userRegistrationId) |
Collection<ClientEventRegistration> |
getActiveRegistrations(String uuid) |
void |
heartbeatResumed(Connection connection)
This event will be fired when the heartbeat is resumed for a connection to a member.
|
void |
heartbeatStopped(Connection connection)
This event will be fired when no heartbeat response is received for
ClientProperty.HEARTBEAT_TIMEOUT milliseconds from the member. |
String |
registerListener(ListenerMessageCodec codec,
EventHandler handler) |
void |
start() |
addEventHandler, getEventExecutor, getEventHandler, handleClientMessage, provideMetrics, removeEventHandler, shutdown
public ClientSmartListenerService(HazelcastClientInstanceImpl client, int eventThreadCount, int eventQueueCapacity)
public String registerListener(ListenerMessageCodec codec, EventHandler handler)
registerListener
in interface ClientListenerService
public boolean deregisterListener(String userRegistrationId)
deregisterListener
in interface ClientListenerService
public void start()
start
in class ClientListenerServiceImpl
public void connectionAdded(Connection connection)
connectionAdded
in interface ConnectionListener
public void connectionRemoved(Connection connection)
connectionRemoved
in interface ConnectionListener
public void heartbeatResumed(Connection connection)
ConnectionHeartbeatListener
heartbeatResumed
in interface ConnectionHeartbeatListener
public void heartbeatStopped(Connection connection)
ConnectionHeartbeatListener
ClientProperty.HEARTBEAT_TIMEOUT
milliseconds from the member.heartbeatStopped
in interface ConnectionHeartbeatListener
public Collection<ClientEventRegistration> getActiveRegistrations(String uuid)
getActiveRegistrations
in class ClientListenerServiceImpl
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.