public interface FlinkActor
extends akka.actor.Actor
The message handling logic is defined in the handleMessage method. This allows to mixin stackable traits which change the message receiving behaviour.
Modifier and Type | Method and Description |
---|---|
Object |
decorateMessage(Object message)
Factory method for messages.
|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Handle incoming messages
|
grizzled.slf4j.Logger |
log() |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.