public interface Stage<M,C extends StageConfig> extends Processor<M>, Configurable<C>
Modifier and Type | Method and Description |
---|---|
ContextFactory |
getContextFactory() |
java.lang.String |
getId() |
java.lang.Class<M> |
getMessageClass() |
MetricRegistry |
getMetricRegistry() |
handleSignal, process
getConfiguration, getStageConfigClass, init
java.lang.String getId()
java.lang.Class<M> getMessageClass()
ContextFactory getContextFactory()
MetricRegistry getMetricRegistry()