An actor has to define its initial receive behavior by implementing the createReceive method.

INTERNAL API

INTERNAL API

INTERNAL API

INTERNAL API

INTERNAL API

Scala API: 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.AbstractActor.ActorContext, which is the Java API of the actor context.

Returns this AbstractActor's ActorContext The ActorContext is not thread safe so do not expose it outside of the AbstractActor.

Returns the ActorRef for this actor.

Same as self().

The reference sender Actor of the currently processed message. This is always a legal destination to send to, even if there is no logical recipient for the reply, in which case it will be sent to the dead letter mailbox.

Same as sender().

WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

The state when the publisher is active, i.e. before the subscriber is attached and when an subscriber is attached. It is allowed to call #onComplete and #onError in this state. It is allowed to call #onNext in this state when #totalDemand is greater than zero.

The state after the stream subscriber has canceled the subscription. It is allowed to call #onNext, #onError, and #onComplete in this state, but the calls will not perform anything.

The terminal state after calling #onComplete. It is not allowed to call #onNext, #onError, and #onComplete in this state.

The terminal state after calling #onError. It is not allowed to call #onNext, #onError, and #onComplete in this state.

Complete the stream. After that you are not allowed to call #onNext, #onError and #onComplete.

Complete the stream. After that you are not allowed to call #onNext, #onError and #onComplete.

After signaling completion the Actor will then stop itself as it has completed the protocol. When #onComplete is called before any Subscriber has had the chance to subscribe to this ActorPublisher the completion signal (and therefore stopping of the Actor as well) will be delayed until such Subscriber arrives.

Terminate the stream with failure. After that you are not allowed to call #onNext, #onError and #onComplete.

Terminate the stream with failure. After that you are not allowed to call #onNext, #onError and #onComplete.

After signaling the Error the Actor will then stop itself as it has completed the protocol. When #onError is called before any Subscriber has had the chance to subscribe to this ActorPublisher the error signal (and therefore stopping of the Actor as well) will be delayed until such Subscriber arrives.

Send an element to the stream subscriber. You are allowed to send as many elements as have been requested by the stream subscriber. This amount can be inquired with #totalDemand. It is only allowed to use onNext when isActive and totalDemand > 0, otherwise onNext will throw IllegalStateException.

User overridable callback: By default it calls preStart().

Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.

User overridable callback.

Is called asynchronously after getContext().stop() is invoked. Empty default implementation.

User overridable callback: By default it disposes of all children and then calls postStop().

Is called on a crashed Actor right BEFORE it is restarted to allow clean up of resources before Actor is terminated.

User overridable callback.

Is called when an Actor is started. Actor are automatically started asynchronously when created. Empty default implementation.

Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.

Convenience factory of the ReceiveBuilder. Creates a new empty ReceiveBuilder.

The 'self' field holds the ActorRef for this actor.

Can be used to send messages to itself:

self ! 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!

Subscription timeout after which this actor will become Canceled and reject any incoming "late" subscriber.

The actor will receive an SubscriptionTimeoutExceeded message upon which it MUST react by performing all necessary cleanup and stopping itself.

Use this feature in order to avoid leaking actors when you suspect that this Publisher may never get subscribed to by some Subscriber.

User overridable definition the strategy to use for supervising child actors.

Total number of requested elements from the stream subscriber. This actor automatically keeps tracks of this amount based on incoming request messages and outgoing onNext.

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

Scala API: User overridable callback: By default it disposes of all children and then calls postStop().