|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.io.PipelineSink<Cmd,Evt>
public abstract class PipelineSink<Cmd,Evt>
A sink which can be attached by PipelineFactory.buildWithSink(Ctx, akka.io.PipelineStage
to a
pipeline when it is being built. The methods are called when commands,
events or their failures occur during evaluation of the pipeline (i.e.
when injection is triggered using the associated PipelineInjector
).
Constructor Summary | |
---|---|
PipelineSink()
|
Method Summary | |
---|---|
void |
onCommand(Cmd cmd)
This callback is invoked for every command generated by the pipeline. |
void |
onCommandFailure(java.lang.Throwable thr)
This callback is invoked if an exception occurred while processing an injected command. |
void |
onEvent(Evt event)
This callback is invoked for every event generated by the pipeline. |
void |
onEventFailure(java.lang.Throwable thr)
This callback is invoked if an exception occurred while processing an injected event. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public PipelineSink()
Method Detail |
---|
public void onCommand(Cmd cmd)
By default this does nothing.
public void onCommandFailure(java.lang.Throwable thr)
By default this will just throw the exception.
public void onEvent(Evt event)
By default this does nothing.
public void onEventFailure(java.lang.Throwable thr)
By default this will just throw the exception.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |