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.

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.