Package 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, RuntimeStage
public interface Processor<M>
Something that can accept and process a message

  • Method Summary

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

  • Method Details

    • process

      void process(M message, com.lucidworks.apollo.pipeline.Context context, StageOutput<M> output) throws Exception
      Process a passed in message
      Parameters:
      message -
      context -
      Throws:
      Exception

    • handleSignal

      void handleSignal(String signal, String value, com.lucidworks.apollo.pipeline.Context context)
      Handle a signal
      Parameters:
      signal -
      value -
      context -