com.lucidworks.apollo.pipeline

Interface StageCallback<M>

public interface StageCallback<M>

Method Summary

Modifier and Type	Method and Description
void	onStageEmit(M message, Context context, String stageId, StageConfig stageConfig, boolean isLast)
void	onStageError(M message, Context context, String stageId, StageConfig stageConfig, Throwable t)
void	onStageEvent(Object event)

Method Detail

onStageEmit

void onStageEmit(M message,
                 Context context,
                 String stageId,
                 StageConfig stageConfig,
                 boolean isLast)

onStageError

void onStageError(M message,
                  Context context,
                  String stageId,
                  StageConfig stageConfig,
                  Throwable t)

onStageEvent

void onStageEvent(Object event)