com.hazelcast.spi.impl.eventservice.impl

Class EventServiceSegment<S>

java.lang.Object

com.hazelcast.spi.impl.eventservice.impl.EventServiceSegment<S>

Type Parameters:

S - the service type for which this segment is responsible

public class EventServiceSegment<S>
extends Object

Segment of the event service. Each segment is responsible for a single service and holds Registrations for that service. The segment is responsible for keeping the number of publications and keeping the registrations. The listener registration defines a specific topic that allows for further granulation of the published events. This allows events to be published for the same service but for a different topic (e.g. for a map service the topics are specific map instance names).

Constructor Summary

Constructors

Constructor and Description
EventServiceSegment(String serviceName, S service)

Method Summary

Modifier and Type	Method and Description
boolean	addRegistration(String topic, Registration registration) Adds a registration for the topic and notifies the listener and service of the listener registration.
ConcurrentMap<String,Registration>	getRegistrationIdMap() Returns the map from registration ID to the listener registration.
ConcurrentMap<String,Collection<Registration>>	getRegistrations()
Collection<Registration>	getRegistrations(String topic, boolean forceCreate) Returns the Registrations for the event topic.
Registration	removeRegistration(String topic, String id) Removes the registration matching the topic and ID.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventServiceSegment

public EventServiceSegment(String serviceName,
                           S service)

Method Detail

getRegistrations

public Collection<Registration> getRegistrations(String topic,
                                                 boolean forceCreate)

Returns the Registrations for the event topic. If there are no registrations and forceCreate, it will create a concurrent set and put it in the registration map.

Parameters:

topic - the event topic

forceCreate - whether to create the registration set if none exists or to return null

Returns:

the collection of registrations for the topic or null if none exists and forceCreate is false

getRegistrationIdMap

public ConcurrentMap<String,Registration> getRegistrationIdMap()

Returns the map from registration ID to the listener registration.

getRegistrations

public ConcurrentMap<String,Collection<Registration>> getRegistrations()

addRegistration

public boolean addRegistration(String topic,
                               Registration registration)

Adds a registration for the topic and notifies the listener and service of the listener registration. Returns if the registration was added. The registration might not be added if an equal instance is already registered.

Parameters:

topic - the event topic

registration - the listener registration

Returns:

if the registration is added

removeRegistration

public Registration removeRegistration(String topic,
                                       String id)

Removes the registration matching the topic and ID. Returns the removed registration or null if none matched.

Parameters:

topic - the registration topic name

id - the registration ID

Returns:

the registration which was removed or null if none matchec