akka.contrib.pattern

Interface ReceivePipeline

All Superinterfaces:

Actor

public interface ReceivePipeline
extends Actor

Trait implementing Receive Pipeline Pattern. Mixin this trait for configuring a chain of interceptors to be applied around Actor's current behavior.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ReceivePipeline.Delegation Result returned by an interceptor PF to determine what/whether to delegate to the next inner interceptor
static class	ReceivePipeline.Done$
static class	ReceivePipeline.HandledCompletely$ Interceptor return value that indicates that the message has been handled completely.
static interface	ReceivePipeline.HandlerResult
static class	ReceivePipeline.Inner
static class	ReceivePipeline.Inner$
static class	ReceivePipeline.InnerAndAfter
static class	ReceivePipeline.InnerAndAfter$
static class	ReceivePipeline.Undefined$

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Method Summary

Modifier and Type	Method and Description
void	aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg) INTERNAL API.
scala.Function1<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>,scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>>	combinedDecorator()
void	pipelineInner(scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation> interceptor) Adds an inner interceptor, it will be applied lastly, near to Actor's original behavior
void	pipelineOuter(scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation> interceptor) Adds an outer interceptor, it will be applied firstly, far from Actor's original behavior
java.lang.Object	toReceive(scala.Function1<java.lang.Object,ReceivePipeline.HandlerResult> handler)

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, context, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Method Detail

pipelineInner

void pipelineInner(scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation> interceptor)

Adds an inner interceptor, it will be applied lastly, near to Actor's original behavior

Parameters:

interceptor - an interceptor

pipelineOuter

void pipelineOuter(scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation> interceptor)

Adds an outer interceptor, it will be applied firstly, far from Actor's original behavior

Parameters:

interceptor - an interceptor

combinedDecorator

scala.Function1<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>,scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> combinedDecorator()

toReceive

java.lang.Object toReceive(scala.Function1<java.lang.Object,ReceivePipeline.HandlerResult> handler)

aroundReceive

void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
                   java.lang.Object msg)

INTERNAL API.

Specified by:

aroundReceive in interface Actor

Parameters:

receive - (undocumented)

msg - (undocumented)