com.lucidworks.apollo.pipeline

Interface Processor<M>

Type Parameters:

M -

All Known Subinterfaces:

Generator<M,C>, Stage<M,C>

All Known Implementing Classes:

AbstractGenerator, AbstractProcessor, AbstractStage, DocumentGenerator, IndexStage, RuntimeStage, SimpleIndexStage

public interface Processor<M>

Something that can accept and process a message

Method Summary

Modifier and Type	Method and Description
void	handleSignal(java.lang.String signal, java.lang.String value, Context context) Handle a signal
void	process(M message, Context context, StageOutput<M> output) Process a passed in message

Method Detail

process

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

Process a passed in message

Parameters:

message -

context -

Throws:

java.lang.Exception

handleSignal

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

Handle a signal

Parameters:

signal -

value -

context -