com.hazelcast.map.impl.querycache.publisher

Class EventPublisherAccumulatorProcessor

java.lang.Object

com.hazelcast.map.impl.querycache.publisher.EventPublisherAccumulatorProcessor

All Implemented Interfaces:

AccumulatorProcessor<Sequenced>

public class EventPublisherAccumulatorProcessor
extends Object
implements AccumulatorProcessor<Sequenced>

Publish events which will be received by subscriber sides.

See Also:

AccumulatorProcessor

Constructor Summary

Constructors

Constructor and Description
EventPublisherAccumulatorProcessor(AccumulatorInfo info, QueryCacheEventService eventService)
EventPublisherAccumulatorProcessor(QueryCacheEventService eventService)

Method Summary

Modifier and Type	Method and Description
void	process(Sequenced sequenced) Processes event.
void	setInfo(AccumulatorInfo info)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventPublisherAccumulatorProcessor

public EventPublisherAccumulatorProcessor(QueryCacheEventService eventService)

EventPublisherAccumulatorProcessor

public EventPublisherAccumulatorProcessor(AccumulatorInfo info,
                                          QueryCacheEventService eventService)

Method Detail

process

public void process(Sequenced sequenced)

Description copied from interface: AccumulatorProcessor

Processes event.

Specified by:

process in interface AccumulatorProcessor<Sequenced>

Parameters:

sequenced - type of event.

setInfo

public void setInfo(AccumulatorInfo info)