akka.io
Interface PipelineInjector<Cmd,Evt>


public interface PipelineInjector<Cmd,Evt>

A handle for injecting commands and events into a pipeline. Commands travel down (or to the right) through the stages, events travel in the opposite direction.

See Also:
PipelineFactory.buildWithSinkFunctions(Ctx, akka.io.PipelineStage, scala.Function1, scala.runtime.BoxedUnit>, scala.Function1, scala.runtime.BoxedUnit>), PipelineFactory.buildWithSink(Ctx, akka.io.PipelineStage, akka.io.PipelineSink)

Method Summary
 void injectCommand(Cmd cmd)
          Inject the given command into the connected pipeline.
 void injectEvent(Evt event)
          Inject the given event into the connected pipeline.
 void managementCommand(java.lang.Object cmd)
          Send a management command to all stages (in an unspecified order).
 

Method Detail

injectCommand

void injectCommand(Cmd cmd)
Inject the given command into the connected pipeline.


injectEvent

void injectEvent(Evt event)
Inject the given event into the connected pipeline.


managementCommand

void managementCommand(java.lang.Object cmd)
Send a management command to all stages (in an unspecified order).