Package akka.routing

Class ResizablePoolCell

java.lang.Object

akka.actor.ActorCell

akka.routing.RoutedActorCell

akka.routing.ResizablePoolCell

All Implemented Interfaces:

AbstractActor.ActorContext, ActorContext, ActorRefFactory, Cell, ClassicActorContextProvider, Children, DeathWatch, Dispatch, FaultHandling, ReceiveTimeout, UntypedActorContext

public final class ResizablePoolCell
extends RoutedActorCell

This approach is chosen for binary compatibility

Nested Class Summary

Nested classes/interfaces inherited from class akka.routing.RoutedActorCell

RoutedActorCell.RouterActorCreator

Constructor Summary

Constructors

Constructor	Description
ResizablePoolCell(ActorSystemImpl _system, InternalActorRef _ref, Props _routerProps, MessageDispatcher _routerDispatcher, Props _routeeProps, InternalActorRef _supervisor, Pool pool)

Method Summary

Modifier and Type	Method	Description
Pool	pool()
protected void	preSuperStart()	Called when router is initialized but before super.start() to be able to do extra initialization in subclass.
void	resize(boolean initial)
Resizer	resizer()
void	sendMessage(Envelope envelope)	Route the message via the router to the selected destination.

Methods inherited from class akka.routing.RoutedActorCell

addRoutee, addRoutees, removeRoutee, removeRoutees, routeeProps, router, routerConfig, start

Methods inherited from class akka.actor.ActorCell

actor, actor_$eq, autoReceiveMessage, become, become, become, become$default$2, classicActorContext, clazz, clearActorCellFields, clearActorFields, contextStack, create, currentMessage, currentMessage_$eq, DefaultState, dispatcher, emptyActorRefSet, emptyBehaviorStack, emptyCancellable, getDispatcher, getParent, getProps, getSelf, getSystem, guardian, handleSupervise, invoke, isLocal, lookupRoot, newActor, newUid, parent, props, provider, publish, receiveMessage, self, sender, setActorFields, splitNameAndUid, stash, SuspendedState, SuspendedWaitForChildrenState, system, systemImpl, systemInvoke, terminatedProps, uid, unbecome, undefinedUid

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.AbstractActor.ActorContext

become, become, cancelReceiveTimeout, findChild, getChild, getChildren, getReceiveTimeout, getSender, setReceiveTimeout

Methods inherited from interface akka.actor.ActorContext

become, child, children, receiveTimeout, setReceiveTimeout, unwatch, watch, watchWith, writeObject

Methods inherited from interface akka.actor.ActorRefFactory

actorFor, actorFor, actorFor, actorFor, actorOf, actorOf, actorSelection, actorSelection, stop

Methods inherited from interface akka.actor.Cell

childrenRefs, getChildByName, getSingleChild, hasMessages, isTerminated, numberOfMessages, restart, resume, sendMessage, sendSystemMessage, stop, suspend

Methods inherited from interface akka.actor.dungeon.Children

_childrenRefsDoNotCallMeDirectly_$eq, _functionRefsDoNotCallMeDirectly_$eq, _nextNameDoNotCallMeDirectly_$eq, actorOf, actorOf, addFunctionRef, addFunctionRef$default$2, attachChild, attachChild, checkName, child, children, childrenRefs, findChild, functionRefs, getAllChildStats, getChild, getChildByName, getChildByRef, getChildren, getFunctionRefOrNobody, getFunctionRefOrNobody$default$2, getSingleChild, initChild, isNormal, isTerminating, makeChild, randomName, randomName, removeChildAndGetStateChange, removeFunctionRef, reserveChild, resumeChildren, setChildrenTerminationReason, setTerminated, stop, stopFunctionRefs, suspendChildren, suspendChildren$default$1, swapChildrenRefs, unreserveChild, waitingForChildrenOrNull

Methods inherited from interface akka.actor.dungeon.DeathWatch

addressTerminated, addWatcher, checkWatchingSame, isWatching, maintainAddressTerminatedSubscription, maintainAddressTerminatedSubscription$default$1, receivedTerminated, removeFromMap, remWatcher, subscribeAddressTerminated, tellWatchersWeDied, terminatedQueued_$eq, terminatedQueuedFor, unsubscribeAddressTerminated, unwatch, unwatchWatchedActors, updateWatching, watch, watchedActorTerminated, watchedBy_$eq, watching_$eq, watchingContains, watchingGet, watchWith

Methods inherited from interface akka.actor.dungeon.Dispatch

_mailboxDoNotCallMeDirectly_$eq, handleException, hasMessages, init, initWithFailure, isTerminated, mailbox, numberOfMessages, restart, resume, sendSystemMessage, serializeAndDeserialize, serializeAndDeserializePayload, stop, suspend, swapMailbox

Methods inherited from interface akka.actor.dungeon.FaultHandling

_failed_$eq, clearFailed, faultCreate, faultRecreate, faultResume, faultSuspend, finishCreate, finishRecreate, finishTerminate, handleChildTerminated, handleFailure, handleInvokeFailure, handleNonFatalOrInterruptedException, isFailed, perpetrator, resumeNonRecursive, setFailed, suspendNonRecursive, terminate

Methods inherited from interface akka.actor.dungeon.ReceiveTimeout

cancelReceiveTimeout, checkReceiveTimeout, checkReceiveTimeout$default$1, receiveTimeout, receiveTimeoutData_$eq, rescheduleReceiveTimeout, setReceiveTimeout

Methods inherited from interface akka.actor.UntypedActorContext

getChild, getChildren

Constructor Detail

ResizablePoolCell

public ResizablePoolCell(ActorSystemImpl _system,
                         InternalActorRef _ref,
                         Props _routerProps,
                         MessageDispatcher _routerDispatcher,
                         Props _routeeProps,
                         InternalActorRef _supervisor,
                         Pool pool)

Method Detail

pool

public Pool pool()

preSuperStart

protected void preSuperStart()

Description copied from class: RoutedActorCell

Called when router is initialized but before super.start() to be able to do extra initialization in subclass.

Overrides:

preSuperStart in class RoutedActorCell

resize

public void resize(boolean initial)

resizer

public Resizer resizer()

sendMessage

public void sendMessage(Envelope envelope)

Description copied from class: RoutedActorCell

Route the message via the router to the selected destination.

Specified by:

sendMessage in interface Cell

Specified by:

sendMessage in interface Dispatch

Overrides:

sendMessage in class RoutedActorCell

Parameters:

envelope - (undocumented)