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) |
void |
handleEventPacket(Packet packet) |
String |
listen(ClientRequest request,
Object key,
EventHandler handler) |
void |
registerFailedListener(ClientCallFuture future) |
void |
registerListener(String uuid,
Integer callId) |
void |
reRegisterListener(String uuid,
String alias,
Integer callId) |
void |
shutdown() |
boolean |
stopListening(BaseClientRemoveListenerRequest request,
String registrationId) |
void |
triggerFailedListeners() |
public ClientListenerServiceImpl(HazelcastClientInstanceImpl client, int eventThreadCount, int eventQueueCapacity)
public String listen(ClientRequest request, Object key, EventHandler handler)
listen
in interface ClientListenerService
public boolean stopListening(BaseClientRemoveListenerRequest request, String registrationId)
stopListening
in interface ClientListenerService
public void registerFailedListener(ClientCallFuture 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 © 2016 Hazelcast, Inc.. All Rights Reserved.