public abstract class ClientListenerServiceImpl extends Object implements ClientListenerService
Modifier and Type | Field and Description |
---|---|
protected HazelcastClientInstanceImpl |
client |
protected ClientExecutionServiceImpl |
executionService |
protected ClientInvocationService |
invocationService |
protected ILogger |
logger |
protected SerializationService |
serializationService |
Constructor and Description |
---|
ClientListenerServiceImpl(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() |
protected EventHandler |
getEventHandler(long callId) |
void |
handleClientMessage(ClientMessage clientMessage,
Connection connection) |
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 ClientExecutionServiceImpl executionService
protected final SerializationService serializationService
protected final ClientInvocationService invocationService
protected final ILogger logger
public ClientListenerServiceImpl(HazelcastClientInstanceImpl client, int eventThreadCount, int eventQueueCapacity)
public void addEventHandler(long callId, EventHandler handler)
protected void removeEventHandler(long callId)
protected EventHandler getEventHandler(long callId)
public void handleClientMessage(ClientMessage clientMessage, Connection connection)
public void shutdown()
public StripedExecutor getEventExecutor()
public void start()
public abstract Collection<ClientEventRegistration> getActiveRegistrations(String uuid)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.