com.lucidworks.apollo.pipeline

Class AbstractStage<M,C extends StageConfig>

java.lang.Object

com.lucidworks.apollo.pipeline.AbstractStage<M,C>

All Implemented Interfaces:

Configurable<C>, Processor<M>, Stage<M,C>

Direct Known Subclasses:

AbstractGenerator, AbstractProcessor

public abstract class AbstractStage<M,C extends StageConfig>
extends java.lang.Object
implements Stage<M,C>

Method Summary

Modifier and Type	Method and Description
C	getConfiguration()
ContextFactory	getContextFactory()
java.lang.String	getId()
MetricRegistry	getMetricRegistry()
void	handleSignal(java.lang.String signal, java.lang.String value, Context context) Handle a signal
void	init()
void	process(M message, Context context, StageOutput<M> output) Implements the default behavior for a stage when it receives a message (which is to simply pass it to the next stage)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.lucidworks.apollo.pipeline.Stage

getMessageClass

Methods inherited from interface com.lucidworks.apollo.pipeline.Configurable

getStageConfigClass

Method Detail

getConfiguration

public C getConfiguration()

Specified by:

getConfiguration in interface Configurable<C extends StageConfig>

init

public void init()

Specified by:

init in interface Configurable<C extends StageConfig>

getId

public java.lang.String getId()

Specified by:

getId in interface Stage<M,C extends StageConfig>

getContextFactory

public ContextFactory getContextFactory()

Specified by:

getContextFactory in interface Stage<M,C extends StageConfig>

getMetricRegistry

public MetricRegistry getMetricRegistry()

Specified by:

getMetricRegistry in interface Stage<M,C extends StageConfig>

process

public void process(M message,
                    Context context,
                    StageOutput<M> output)
             throws java.lang.Exception

Implements the default behavior for a stage when it receives a message (which is to simply pass it to the next stage)

Specified by:

process in interface Processor<M>

Parameters:

message -

context -

Throws:

java.lang.Exception

handleSignal

public void handleSignal(java.lang.String signal,
                         java.lang.String value,
                         Context context)

Description copied from interface: Processor

Handle a signal

Specified by:

handleSignal in interface Processor<M>