Type alias because traits cannot have companion objects.
Type alias because traits cannot have companion objects.
A Receive block that runs after the coordinated transaction.
A Receive block that runs after the coordinated transaction.
The Receive block to run inside the coordinated transaction.
The Receive block to run inside the coordinated transaction.
Java API for become
Java API for become
Changes the Actor's behavior to become the new 'Receive' (PartialFunction[Any, Unit]) handler.
Changes the Actor's behavior to become the new 'Receive' (PartialFunction[Any, Unit]) handler. Puts the behavior on top of the hotswap stack. If "discardOld" is true, an unbecome will be issued prior to pushing the new behavior to the stack
A Receive block that runs before the coordinated transaction is entered.
A Receive block that runs before the coordinated transaction is entered.
Returns the 'self' reference with the API.
Returns the 'self' reference with the API.
Override this method to coordinate with other transactors.
Override this method to coordinate with other transactors. The other transactors are added to the coordinated transaction barrier and sent a Coordinated message. The message to send can be specified or otherwise the same message as received is sent. Use the 'include' and 'sendTo' methods to easily create the set of transactors to be involved.
User overridable callback.
User overridable callback.
Is called on the crashed Actor to give it the option of producing the Actor's reincarnation. If it returns None, which is the default, the initially provided actor factory is used.
Warning: Propagating state from a crashed actor carries the risk of proliferating the cause of the error. Consider let-it-crash first.
Returns the 'self' reference with the API.
Returns the 'self' reference with the API.
For including one other actor in this coordinated transaction and specifying the message to send.
For including one other actor in this coordinated transaction and specifying the
message to send. Use as the result in coordinated.
For including one other actor in this coordinated transaction and sending them the same message as received.
For including one other actor in this coordinated transaction and sending
them the same message as received. Use as the result in coordinated.
Is the actor able to handle the message passed in as arguments?
Is the actor able to handle the message passed in as arguments?
Empty set of transactors to send to.
Bypass transactionality and behave like a normal actor.
Bypass transactionality and behave like a normal actor.
Implement a general pattern for using coordinated transactions.
Implement a general pattern for using coordinated transactions.
Option[ActorRef] representation of the 'self' ActorRef reference.
Option[ActorRef] representation of the 'self' ActorRef reference.
Mainly for internal use, functions as the implicit sender references when invoking one of the message send functions ('!', '!!' and '!!!').
User overridable callback.
User overridable callback.
Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.
User overridable callback.
User overridable callback.
Is called when 'actor.stop()' is invoked.
User overridable callback.
User overridable callback.
Is called on a crashed Actor right BEFORE it is restarted to allow clean up of resources before Actor is terminated.
User overridable callback.
User overridable callback.
Is called on a crashed Actor right BEFORE it is restarted to allow clean up of resources before Actor is terminated. Override either the variant with or without the currentMessage argument.
User overridable callback.
User overridable callback.
Is called when an Actor is started by invoking 'actor.start()'.
User overridable callback/setting.
User overridable callback/setting.
Partial function implementing the actor logic. To be implemented by concrete actor class.
Example code:
def receive = {
case Ping =>
println("got a 'Ping' message")
self.reply("pong")
case OneWay =>
println("got a 'OneWay' message")
case unknown =>
println("unknown message: " + unknown)
}
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 ! messageHere you also find most of the Actor API.
For example fields like:
self.dispatcher = ... self.trapExit = ... self.faultHandler = ... self.lifeCycle = ... self.sender
Here you also find methods like:
self.reply(..) self.link(..) self.unlink(..) self.start(..) self.stop(..)
For including another actor in this coordinated transaction and specifying the message to send.
For including another actor in this coordinated transaction and specifying the
message to send. Use to create the result in coordinated.
For including another actor in this coordinated transaction and sending them the same message as received.
For including another actor in this coordinated transaction and sending
them the same message as received. Use to create the result in coordinated.
Some[ActorRef] representation of the 'self' ActorRef reference.
Some[ActorRef] representation of the 'self' ActorRef reference.
Mainly for internal use, functions as the implicit sender references when invoking the 'forward' function.
Create default transaction factory.
Create default transaction factory. Override to provide custom configuration.
Reverts the Actor behavior to the previous one in the hotswap stack.
Reverts the Actor behavior to the previous one in the hotswap stack.
User overridable callback.
User overridable callback.
Is called when a message isn't handled by the current behavior of the actor by default it throws an UnhandledMessageException
An UntypedActor version of transactor for using from Java.