com.hazelcast.client.spi.impl.listener

Class AbstractClientListenerService

java.lang.Object

com.hazelcast.client.spi.impl.listener.AbstractClientListenerService

All Implemented Interfaces:

ClientListenerService, MetricsProvider, ConnectionListener

Direct Known Subclasses:

NonSmartClientListenerService, SmartClientListenerService

public abstract class AbstractClientListenerService
extends Object
implements ClientListenerService, MetricsProvider, ConnectionListener

Field Summary

Fields

Modifier and Type	Field and Description
protected HazelcastClientInstanceImpl	client
protected long	invocationRetryPauseMillis
protected long	invocationTimeoutMillis
protected Map<ClientRegistrationKey,Map<Connection,ClientEventRegistration>>	registrations
protected SerializationService	serializationService

Method Summary

Modifier and Type	Method and Description
void	addEventHandler(long callId, EventHandler handler)
void	connectionAdded(Connection connection)
void	connectionRemoved(Connection connection)
boolean	deregisterListener(String userRegistrationId)
Collection<ClientEventRegistration>	getActiveRegistrations(String uuid)
StripedExecutor	getEventExecutor()
Map<Long,EventHandler>	getEventHandlers()
Map<ClientRegistrationKey,Map<Connection,ClientEventRegistration>>	getRegistrations()
void	handleClientMessage(ClientMessage clientMessage)
protected void	invoke(ClientRegistrationKey registrationKey, Connection connection)
void	provideMetrics(MetricsRegistry registry)
String	registerListener(ListenerMessageCodec codec, EventHandler handler)
void	removeEventHandler(long callId)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

client

protected final HazelcastClientInstanceImpl client

serializationService

protected final SerializationService serializationService

invocationTimeoutMillis

protected final long invocationTimeoutMillis

invocationRetryPauseMillis

protected final long invocationRetryPauseMillis

registrations

protected final Map<ClientRegistrationKey,Map<Connection,ClientEventRegistration>> registrations

Method Detail

registerListener

public String registerListener(ListenerMessageCodec codec,
                               EventHandler handler)

Specified by:

registerListener in interface ClientListenerService

deregisterListener

public boolean deregisterListener(String userRegistrationId)

Specified by:

deregisterListener in interface ClientListenerService

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider

addEventHandler

public void addEventHandler(long callId,
                            EventHandler handler)

handleClientMessage

public void handleClientMessage(ClientMessage clientMessage)

invoke

protected void invoke(ClientRegistrationKey registrationKey,
                      Connection connection)
               throws Exception

Throws:

Exception

connectionAdded

public void connectionAdded(Connection connection)

Specified by:

connectionAdded in interface ConnectionListener

shutdown

public void shutdown()

start

public void start()

connectionRemoved

public void connectionRemoved(Connection connection)

Specified by:

connectionRemoved in interface ConnectionListener

getEventExecutor

public StripedExecutor getEventExecutor()

getActiveRegistrations

public Collection<ClientEventRegistration> getActiveRegistrations(String uuid)

getRegistrations

public Map<ClientRegistrationKey,Map<Connection,ClientEventRegistration>> getRegistrations()

getEventHandlers

public Map<Long,EventHandler> getEventHandlers()

removeEventHandler

public void removeEventHandler(long callId)