com.hazelcast.map.impl.querycache.publisher

Class PublisherAccumulatorHandler

java.lang.Object

com.hazelcast.map.impl.querycache.publisher.PublisherAccumulatorHandler

All Implemented Interfaces:

AccumulatorHandler<Sequenced>

public class PublisherAccumulatorHandler
extends Object
implements AccumulatorHandler<Sequenced>

Handler for processing of event data in an Accumulator. Processing is done by the help of AccumulatorProcessor.

See Also:

EventPublisherAccumulatorProcessor

Constructor Summary

Constructors

Constructor and Description
PublisherAccumulatorHandler(QueryCacheContext context, AccumulatorProcessor<Sequenced> processor)

Method Summary

Modifier and Type	Method and Description
void	handle(Sequenced eventData, boolean lastElement) Handles element.
void	reset() Resets this handler to its initial state.

Methods inherited from class java.lang.Object

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

Constructor Detail

PublisherAccumulatorHandler

public PublisherAccumulatorHandler(QueryCacheContext context,
                                   AccumulatorProcessor<Sequenced> processor)

Method Detail

handle

public void handle(Sequenced eventData,
                   boolean lastElement)

Description copied from interface: AccumulatorHandler

Handles element.

Specified by:

handle in interface AccumulatorHandler<Sequenced>

Parameters:

eventData - the element to be processed.

lastElement - true if this is the last element got from the Accumulator, otherwise false.

reset

public void reset()

Description copied from interface: AccumulatorHandler

Resets this handler to its initial state.

Specified by:

reset in interface AccumulatorHandler<Sequenced>