com.hazelcast.spi.impl

Class EventServiceImpl

java.lang.Object

com.hazelcast.spi.impl.EventServiceImpl

All Implemented Interfaces:

EventService

public class EventServiceImpl
extends Object
implements EventService

Author:

mdogan 12/14/12

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EventServiceImpl.DeregistrationOperation
static class	EventServiceImpl.EmptyFilter
static class	EventServiceImpl.EventPacket
static class	EventServiceImpl.PostJoinRegistrationOperation
static class	EventServiceImpl.Registration
static class	EventServiceImpl.RegistrationOperation
static class	EventServiceImpl.SendEventOperation

Method Summary

Modifier and Type	Method and Description
void	deregisterAllListeners(String serviceName, String topic)
boolean	deregisterListener(String serviceName, String topic, Object id)
int	getEventQueueCapacity()
int	getEventQueueSize()
int	getEventThreadCount()
EventServiceImpl.PostJoinRegistrationOperation	getPostJoinOperation()
Collection<EventRegistration>	getRegistrations(String serviceName, String topic)
EventRegistration[]	getRegistrationsAsArray(String serviceName, String topic)
void	publishEvent(String serviceName, Collection<EventRegistration> registrations, Object event, int orderKey)
void	publishEvent(String serviceName, EventRegistration registration, Object event, int orderKey)
EventRegistration	registerListener(String serviceName, String topic, EventFilter filter, Object listener)
EventRegistration	registerListener(String serviceName, String topic, Object listener)
EventRegistration	registerLocalListener(String serviceName, String topic, EventFilter filter, Object listener)
EventRegistration	registerLocalListener(String serviceName, String topic, Object listener)

Methods inherited from class java.lang.Object

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

Method Detail

getEventThreadCount

public int getEventThreadCount()

Specified by:

getEventThreadCount in interface EventService

getEventQueueCapacity

public int getEventQueueCapacity()

Specified by:

getEventQueueCapacity in interface EventService

getEventQueueSize

public int getEventQueueSize()

Specified by:

getEventQueueSize in interface EventService

registerLocalListener

public EventRegistration registerLocalListener(String serviceName,
                                               String topic,
                                               Object listener)

Specified by:

registerLocalListener in interface EventService

registerLocalListener

public EventRegistration registerLocalListener(String serviceName,
                                               String topic,
                                               EventFilter filter,
                                               Object listener)

Specified by:

registerLocalListener in interface EventService

registerListener

public EventRegistration registerListener(String serviceName,
                                          String topic,
                                          Object listener)

Specified by:

registerListener in interface EventService

registerListener

public EventRegistration registerListener(String serviceName,
                                          String topic,
                                          EventFilter filter,
                                          Object listener)

Specified by:

registerListener in interface EventService

deregisterListener

public boolean deregisterListener(String serviceName,
                                  String topic,
                                  Object id)

Specified by:

deregisterListener in interface EventService

deregisterAllListeners

public void deregisterAllListeners(String serviceName,
                                   String topic)

Specified by:

deregisterAllListeners in interface EventService

getRegistrationsAsArray

public EventRegistration[] getRegistrationsAsArray(String serviceName,
                                                   String topic)

Specified by:

getRegistrationsAsArray in interface EventService

getRegistrations

public Collection<EventRegistration> getRegistrations(String serviceName,
                                                      String topic)

Specified by:

getRegistrations in interface EventService

publishEvent

public void publishEvent(String serviceName,
                         EventRegistration registration,
                         Object event,
                         int orderKey)

Specified by:

publishEvent in interface EventService

publishEvent

public void publishEvent(String serviceName,
                         Collection<EventRegistration> registrations,
                         Object event,
                         int orderKey)

Specified by:

publishEvent in interface EventService

getPostJoinOperation

public EventServiceImpl.PostJoinRegistrationOperation getPostJoinOperation()