public abstract class AbstractClientListenerService extends Object implements ClientListenerService, MetricsProvider
Modifier and Type | Field and Description |
---|---|
protected HazelcastClientInstanceImpl |
client |
protected ILogger |
logger |
protected ScheduledExecutorService |
registrationExecutor |
protected SerializationService |
serializationService |
Constructor and Description |
---|
AbstractClientListenerService(HazelcastClientInstanceImpl client,
int eventThreadCount,
int eventQueueCapacity) |
Modifier and Type | Method and Description |
---|---|
void |
addEventHandler(long callId,
EventHandler handler) |
abstract Collection<ClientEventRegistration> |
getActiveRegistrations(String uuid) |
StripedExecutor |
getEventExecutor() |
void |
handleClientMessage(ClientMessage clientMessage,
Connection connection) |
void |
provideMetrics(MetricsRegistry registry) |
protected void |
removeEventHandler(long callId) |
void |
shutdown() |
void |
start() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
deregisterListener, registerListener
protected final HazelcastClientInstanceImpl client
protected final SerializationService serializationService
protected final ScheduledExecutorService registrationExecutor
protected final ILogger logger
public AbstractClientListenerService(HazelcastClientInstanceImpl client, int eventThreadCount, int eventQueueCapacity)
public void provideMetrics(MetricsRegistry registry)
provideMetrics
in interface MetricsProvider
public void addEventHandler(long callId, EventHandler handler)
protected void removeEventHandler(long callId)
public void handleClientMessage(ClientMessage clientMessage, Connection connection)
public void shutdown()
public void start()
public StripedExecutor getEventExecutor()
public abstract Collection<ClientEventRegistration> getActiveRegistrations(String uuid)
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.