Package | Description |
---|---|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.internal.nearcache.impl.invalidation |
Invalidations for Near Cache.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.event | |
com.hazelcast.spi |
Provides interfaces/classes for the Hazelcast SPI for building distributed data structures and services.
|
com.hazelcast.spi.impl.eventservice |
Contains the code for the
InternalEventService . |
com.hazelcast.spi.impl.eventservice.impl |
Contains the code for the
InternalEventService implementation. |
Modifier and Type | Method and Description |
---|---|
void |
CacheEventListenerAdaptor.onDeregister(CacheService cacheService,
String serviceName,
String topic,
EventRegistration registration) |
void |
CacheEventListenerAdaptor.onRegister(CacheService cacheService,
String serviceName,
String topic,
EventRegistration registration) |
Modifier and Type | Field and Description |
---|---|
protected IFunction<EventRegistration,Boolean> |
Invalidator.eventFilter |
static IFunction<EventRegistration,Boolean> |
InvalidationUtils.TRUE_FILTER |
Constructor and Description |
---|
BatchInvalidator(String serviceName,
int batchSize,
int batchFrequencySeconds,
IFunction<EventRegistration,Boolean> eventFilter,
NodeEngine nodeEngine) |
Invalidator(String serviceName,
IFunction<EventRegistration,Boolean> eventFilter,
NodeEngine nodeEngine) |
NonStopInvalidator(String serviceName,
IFunction<EventRegistration,Boolean> eventFilter,
NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
void |
MapService.onDeregister(Object service,
String serviceName,
String topic,
EventRegistration registration) |
void |
MapService.onRegister(Object service,
String serviceName,
String topic,
EventRegistration registration) |
Modifier and Type | Method and Description |
---|---|
protected Collection<EventRegistration> |
MapEventPublisherImpl.getRegistrations(String mapName)
Return all listener registrations for the map with
mapName . |
Modifier and Type | Method and Description |
---|---|
protected void |
MapEventPublisherImpl.publishEventInternal(Collection<EventRegistration> registrations,
Object eventData,
int orderKey) |
Modifier and Type | Method and Description |
---|---|
EventRegistration[] |
EventService.getRegistrationsAsArray(String serviceName,
String topic)
Returns all registrations belonging to the given service and topic as an array.
|
EventRegistration |
EventService.registerListener(String serviceName,
String topic,
EventFilter filter,
Object listener)
Registers a listener on all cluster nodes with an event filter.
|
EventRegistration |
EventService.registerListener(String serviceName,
String topic,
Object listener)
Registers a listener on all cluster nodes.
|
EventRegistration |
EventService.registerLocalListener(String serviceName,
String topic,
EventFilter filter,
Object listener)
Registers a local only listener with an event filter.
|
EventRegistration |
EventService.registerLocalListener(String serviceName,
String topic,
Object listener)
Registers a local only listener.
|
Modifier and Type | Method and Description |
---|---|
Collection<EventRegistration> |
EventService.getRegistrations(String serviceName,
String topic)
Returns all registrations belonging to the given service and topic.
|
Modifier and Type | Method and Description |
---|---|
void |
NotifiableEventListener.onDeregister(S service,
String serviceName,
String topic,
EventRegistration registration)
Called when this listener deregistered from
EventService . |
void |
NotifiableEventListener.onRegister(S service,
String serviceName,
String topic,
EventRegistration registration)
Called when this listener registered to
EventService . |
void |
EventService.publishEvent(String serviceName,
EventRegistration registration,
Object event,
int orderKey)
Publishes an event for a specific event registration.
|
Modifier and Type | Method and Description |
---|---|
void |
EventService.publishEvent(String serviceName,
Collection<EventRegistration> registrations,
Object event,
int orderKey)
Publishes an event for multiple event registrations.
|
void |
EventService.publishRemoteEvent(String serviceName,
Collection<EventRegistration> registrations,
Object event,
int orderKey)
Publishes an event for multiple event registrations, excluding local ones.
|
Modifier and Type | Method and Description |
---|---|
void |
InternalEventService.close(EventRegistration eventRegistration)
Closes an EventRegistration.
|
Modifier and Type | Class and Description |
---|---|
class |
Registration |
Modifier and Type | Method and Description |
---|---|
EventRegistration[] |
EventServiceImpl.getRegistrationsAsArray(String serviceName,
String topic) |
EventRegistration |
EventServiceImpl.registerListener(String serviceName,
String topic,
EventFilter filter,
Object listener) |
EventRegistration |
EventServiceImpl.registerListener(String serviceName,
String topic,
Object listener) |
EventRegistration |
EventServiceImpl.registerLocalListener(String serviceName,
String topic,
EventFilter filter,
Object listener) |
EventRegistration |
EventServiceImpl.registerLocalListener(String serviceName,
String topic,
Object listener) |
Modifier and Type | Method and Description |
---|---|
Collection<EventRegistration> |
EventServiceImpl.getRegistrations(String serviceName,
String topic)
Returns all registrations belonging to the given service and topic.
|
Modifier and Type | Method and Description |
---|---|
void |
EventServiceImpl.close(EventRegistration eventRegistration) |
void |
EventServiceImpl.publishEvent(String serviceName,
EventRegistration registration,
Object event,
int orderKey) |
Modifier and Type | Method and Description |
---|---|
void |
EventServiceImpl.publishEvent(String serviceName,
Collection<EventRegistration> registrations,
Object event,
int orderKey) |
void |
EventServiceImpl.publishRemoteEvent(String serviceName,
Collection<EventRegistration> registrations,
Object event,
int orderKey)
Publishes an event for multiple event registrations, excluding local ones.
|
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.