trait Act extends Actor
This trait provides a DSL for writing the inner workings of an actor, e.g. for quickly trying things out in the REPL. It makes the following keywords available:
become
mapped tocontext.become(_, discardOld = true)
becomeStacked
mapped tocontext.become(_, discardOld = false)
unbecome
mapped tocontext.unbecome
setup
for implementingpreStart()
whenFailing
for implementingpreRestart()
whenRestarted
for implementingpostRestart()
teardown
for implementingpostStop
Using the life-cycle keywords multiple times results in replacing the content of the respective hook.
- Source
- Creators.scala
- Alphabetic
- By Inheritance
- Act
- Actor
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Type Members
-
type
Receive = PartialFunction[Any, Unit]
- Definition Classes
- Actor
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from ActorDSL.Act to any2stringadd[ActorDSL.Act] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (ActorDSL.Act, B)
- Implicit
- This member is added by an implicit conversion from ActorDSL.Act to ArrowAssoc[ActorDSL.Act] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
AllForOneStrategy: actor.AllForOneStrategy.type
- See also
-
def
Escalate: SupervisorStrategy.Escalate.type
- See also
-
def
OneForOneStrategy: actor.OneForOneStrategy.type
- See also
-
def
Restart: SupervisorStrategy.Restart.type
- See also
-
def
Resume: SupervisorStrategy.Resume.type
- See also
-
def
Stop: SupervisorStrategy.Stop.type
- See also
-
def
aroundPostRestart(reason: Throwable): Unit
Can be overridden to intercept calls to
postRestart
. -
def
aroundPostStop(): Unit
Can be overridden to intercept calls to
postStop
. -
def
aroundPreRestart(reason: Throwable, message: Option[Any]): Unit
Can be overridden to intercept calls to
preRestart
. -
def
aroundPreStart(): Unit
Can be overridden to intercept calls to
preStart
. -
def
aroundReceive(receive: Actor.Receive, msg: Any): Unit
INTERNAL API.
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
become(r: Receive): Unit
Replace the behavior at the top of the behavior stack for this actor.
Replace the behavior at the top of the behavior stack for this actor. The stack is cleared upon restart. Use
unbecome()
to pop an element off this stack orbecomeStacked()
to push a new element on top of it. -
def
becomeStacked(r: Receive): Unit
Add the given behavior on top of the behavior stack for this actor.
Add the given behavior on top of the behavior stack for this actor. This stack is cleared upon restart. Use
unbecome()
to pop an element off this stack. -
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
implicit
val
context: ActorContext
Stores the context for this actor, including self, and sender.
Stores the context for this actor, including self, and sender. It is implicit to support operations such as
forward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
akka.actor.ActorContext is the Scala API.
getContext
returns a akka.actor.UntypedActorContext, which is the Java API of the actor context.- Definition Classes
- Actor
-
def
ensuring(cond: (ActorDSL.Act) ⇒ Boolean, msg: ⇒ Any): ActorDSL.Act
- Implicit
- This member is added by an implicit conversion from ActorDSL.Act to Ensuring[ActorDSL.Act] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (ActorDSL.Act) ⇒ Boolean): ActorDSL.Act
- Implicit
- This member is added by an implicit conversion from ActorDSL.Act to Ensuring[ActorDSL.Act] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): ActorDSL.Act
- Implicit
- This member is added by an implicit conversion from ActorDSL.Act to Ensuring[ActorDSL.Act] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): ActorDSL.Act
- Implicit
- This member is added by an implicit conversion from ActorDSL.Act to Ensuring[ActorDSL.Act] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from ActorDSL.Act to StringFormat[ActorDSL.Act] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
postRestart(cause: Throwable): Unit
User overridable callback: By default it calls
preStart()
. -
def
postStop(): Unit
User overridable callback.
-
def
preRestart(cause: Throwable, msg: Option[Any]): Unit
User overridable callback: By default it disposes of all children and then calls
postStop()
. -
def
preStart(): Unit
User overridable callback.
-
def
receive: Receive
Default behavior of the actor is empty, use
become
to change this. -
implicit final
val
self: ActorRef
The 'self' field holds the ActorRef for this actor.
The 'self' field holds the ActorRef for this actor.
Can be used to send messages to itself:
self ! message
- Definition Classes
- Actor
-
final
def
sender(): ActorRef
The reference sender Actor of the last received message.
The reference sender Actor of the last received message. Is defined if the message was sent from another Actor, else
deadLetters
in akka.actor.ActorSystem.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
- Definition Classes
- Actor
-
def
superviseWith(s: SupervisorStrategy): Unit
Set the supervisor strategy of this actor, i.e.
Set the supervisor strategy of this actor, i.e. how it supervises its children.
-
def
supervisorStrategy: SupervisorStrategy
User overridable definition the strategy to use for supervising child actors.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
unbecome(): Unit
Pop the active behavior from the behavior stack of this actor.
Pop the active behavior from the behavior stack of this actor. This stack is cleared upon restart.
-
def
unhandled(message: Any): Unit
User overridable callback.
User overridable callback.
Is called when a message isn't handled by the current behavior of the actor by default it fails with either a akka.actor.DeathPactException (in case of an unhandled akka.actor.Terminated message) or publishes an akka.actor.UnhandledMessage to the actor's system's akka.event.EventStream
- Definition Classes
- Actor
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
whenFailing(body: (Throwable, Option[Any]) ⇒ Unit): Unit
Replace the
preRestart
action with the supplied function.Replace the
preRestart
action with the supplied function. Default action is to callsuper.preRestart()
, which will kill all children and invokepostStop()
. -
def
whenRestarted(body: (Throwable) ⇒ Unit): Unit
Replace the
postRestart
action with the supplied function.Replace the
postRestart
action with the supplied function. Default action is to callsuper.postRestart
which will callpreStart()
. -
def
whenStarting(body: ⇒ Unit): Unit
Replace the
preStart
action with the supplied thunk.Replace the
preStart
action with the supplied thunk. Default action is to callsuper.preStart()
-
def
whenStopping(body: ⇒ Unit): Unit
Replace the
postStop
action with the supplied thunk.Replace the
postStop
action with the supplied thunk. Default action is to callsuper.postStop
. -
def
→[B](y: B): (ActorDSL.Act, B)
- Implicit
- This member is added by an implicit conversion from ActorDSL.Act to ArrowAssoc[ActorDSL.Act] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc