com.arakelian.elastic.bulk.event

Class AbstractIndexerEventHandler

java.lang.Object

com.arakelian.elastic.bulk.event.AbstractIndexerEventHandler

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<IndexerEvent>

public abstract class AbstractIndexerEventHandler
extends java.lang.Object
implements com.lmax.disruptor.EventHandler<IndexerEvent>

Constructor Summary

Constructors

Constructor and Description
AbstractIndexerEventHandler()

Method Summary

Modifier and Type	Method and Description
protected abstract void	handle(IndexerEvent event, long sequence, boolean endOfBatch)
void	onEvent(IndexerEvent event, long sequence, boolean endOfBatch)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractIndexerEventHandler

public AbstractIndexerEventHandler()

Method Detail

onEvent

public void onEvent(IndexerEvent event,
                    long sequence,
                    boolean endOfBatch)
             throws java.lang.Exception

Specified by:

onEvent in interface com.lmax.disruptor.EventHandler<IndexerEvent>

Throws:

java.lang.Exception

handle

protected abstract void handle(IndexerEvent event,
                               long sequence,
                               boolean endOfBatch)
                        throws java.lang.Exception

Throws:

java.lang.Exception