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>

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NOW_KEY

Method Summary

Modifier and Type	Method and Description
C	getConfiguration()
ConfigurationComponent	getConfigurationComponent()
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()
boolean	managedModeEnabled()
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

Field Detail

NOW_KEY

public static final java.lang.String NOW_KEY

See Also:

Constant Field Values

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>

getConfigurationComponent

public ConfigurationComponent getConfigurationComponent()

managedModeEnabled

public boolean managedModeEnabled()

Specified by:

managedModeEnabled in interface Stage<M,C extends StageConfig>