com.hazelcast.client.spi.impl
public final class ClientListenerServiceImpl extends Object implements ClientListenerService
Constructor and Description |
---|
ClientListenerServiceImpl(HazelcastClientInstanceImpl client,
int eventThreadCount,
int eventQueueCapacity) |
Modifier and Type | Method and Description |
---|---|
String |
deRegisterListener(String alias) |
StripedExecutor |
getEventExecutor() |
void |
handleEventPacket(Packet packet) |
void |
registerFailedListener(ClientInvocation future) |
void |
registerListener(String uuid,
Integer callId) |
void |
reRegisterListener(String uuid,
String alias,
Integer callId) |
void |
shutdown() |
String |
startListening(ClientRequest request,
Object key,
EventHandler handler) |
boolean |
stopListening(BaseClientRemoveListenerRequest request,
String registrationId) |
void |
triggerFailedListeners() |
public ClientListenerServiceImpl(HazelcastClientInstanceImpl client, int eventThreadCount, int eventQueueCapacity)
public StripedExecutor getEventExecutor()
public String startListening(ClientRequest request, Object key, EventHandler handler)
startListening
in interface ClientListenerService
public boolean stopListening(BaseClientRemoveListenerRequest request, String registrationId)
stopListening
in interface ClientListenerService
public void registerFailedListener(ClientInvocation future)
public void triggerFailedListeners()
public void registerListener(String uuid, Integer callId)
registerListener
in interface ClientListenerService
public String deRegisterListener(String alias)
deRegisterListener
in interface ClientListenerService
public void handleEventPacket(Packet packet)
public void shutdown()
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.