com.lucidworks.apollo.pipeline

Class RuntimeStage<M>

java.lang.Object

com.lucidworks.apollo.pipeline.RuntimeStage<M>

Type Parameters:

M -

All Implemented Interfaces:

Configurable<StageConfig>, Lifecycle, Processor<M>, Stage<M,StageConfig>, StageOutput<M>

public class RuntimeStage<M>
extends java.lang.Object
implements Stage<M,StageConfig>, Lifecycle, StageOutput<M>

Decorates a Stage instance with some telemetry and bounds checking

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RuntimeStage.ThrowableAndMessage<M>

Constructor Summary

Constructors

Constructor and Description
RuntimeStage(Stage<M,C> delegate, C delegateConfig, <any> next, MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method and Description
boolean	evaluateConditionalScript(M message, Context context)
StageConfig	getConfiguration()
ContextFactory	getContextFactory()
Stage<M,? extends StageConfig>	getDelegate()
StageConfig	getDelegateConfig()
java.lang.String	getId()
int	getInflightMessageCount()
java.lang.Class<M>	getMessageClass()
MetricRegistry	getMetricRegistry()
<any>	getNext()
java.util.Collection<RuntimeStage.ThrowableAndMessage<M>>	getRecentErrors()
void	handleSignal(java.lang.String signal, java.lang.String value, Context context) Handle a signal
void	init()
boolean	initManagedModeEnabled()
boolean	managedModeEnabled()
void	process(M message, Context context, StageOutput<M> unused) Determine if the current stage should run, and if so run it Also collect some metrics and handle errors
void	send(M message, Context context) Send a message to the next stage in the pipeline, if set
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

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

getStageConfigClass

Constructor Detail

RuntimeStage

public RuntimeStage(Stage<M,C> delegate,
                    C delegateConfig,
                    <any> next,
                    MetricRegistry metricRegistry)

Method Detail

getDelegate

public Stage<M,? extends StageConfig> getDelegate()

getDelegateConfig

public StageConfig getDelegateConfig()

getNext

public <any> getNext()

process

public void process(M message,
                    Context context,
                    StageOutput<M> unused)

Determine if the current stage should run, and if so run it Also collect some metrics and handle errors

Specified by:

process in interface Processor<M>

Parameters:

message -

context -

unused -

send

public void send(M message,
                 Context context)

Send a message to the next stage in the pipeline, if set

Specified by:

send in interface StageOutput<M>

Parameters:

message -

context -

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>

getContextFactory

public ContextFactory getContextFactory()

Specified by:

getContextFactory in interface Stage<M,StageConfig>

getId

public java.lang.String getId()

Specified by:

getId in interface Stage<M,StageConfig>

getMessageClass

public java.lang.Class<M> getMessageClass()

Specified by:

getMessageClass in interface Stage<M,StageConfig>

getMetricRegistry

public MetricRegistry getMetricRegistry()

Specified by:

getMetricRegistry in interface Stage<M,StageConfig>

managedModeEnabled

public boolean managedModeEnabled()

Specified by:

managedModeEnabled in interface Stage<M,StageConfig>

getConfiguration

public StageConfig getConfiguration()

Specified by:

getConfiguration in interface Configurable<StageConfig>

initManagedModeEnabled

public boolean initManagedModeEnabled()

init

public void init()

Specified by:

init in interface Configurable<StageConfig>

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

getInflightMessageCount

public int getInflightMessageCount()

getRecentErrors

public java.util.Collection<RuntimeStage.ThrowableAndMessage<M>> getRecentErrors()

evaluateConditionalScript

public boolean evaluateConditionalScript(M message,
                                         Context context)
                                  throws java.lang.Exception

Throws:

java.lang.Exception