akka.zeromq
Class ConcurrentSocketActor
java.lang.Object
akka.zeromq.ConcurrentSocketActor
- All Implemented Interfaces:
- Actor
public class ConcurrentSocketActor
- extends java.lang.Object
- implements Actor
Method Summary |
void |
postRestart(java.lang.Throwable reason)
User overridable callback: By default it calls preStart() . |
void |
postStop()
User overridable callback. |
void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
User overridable callback: '''By default it disposes of all children and then calls postStop() .''' |
void |
preStart()
User overridable callback. |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function
with the actor logic. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConcurrentSocketActor
public ConcurrentSocketActor(scala.collection.immutable.Seq<SocketOption> params)
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
- Description copied from interface:
Actor
- This defines the initial actor behavior, it must return a partial function
with the actor logic.
- Specified by:
receive
in interface Actor
- Returns:
- (undocumented)
preStart
public void preStart()
- Description copied from interface:
Actor
- User overridable callback.
Is called when an Actor is started.
Actors are automatically started asynchronously when created.
Empty default implementation.
- Specified by:
preStart
in interface Actor
preRestart
public void preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
- Description copied from interface:
Actor
- User overridable callback: '''By default it disposes of all children and then calls
postStop()
.'''
- Specified by:
preRestart
in interface Actor
- Parameters:
reason
- the Throwable that caused the restart to happenmessage
- optionally the current message the actor processed when failing, if applicable
Is called on a crashed Actor right BEFORE it is restarted to allow clean
up of resources before Actor is terminated.
postRestart
public void postRestart(java.lang.Throwable reason)
- Description copied from interface:
Actor
- User overridable callback: By default it calls
preStart()
.
- Specified by:
postRestart
in interface Actor
- Parameters:
reason
- the Throwable that caused the restart to happen
Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.
postStop
public void postStop()
- Description copied from interface:
Actor
- User overridable callback.
Is called asynchronously after 'actor.stop()' is invoked.
Empty default implementation.
- Specified by:
postStop
in interface Actor