akka.routing
Class ResizablePoolCell

java.lang.Object
  akka.actor.ActorCell
      akka.routing.RoutedActorCell
          akka.routing.ResizablePoolCell

All Implemented Interfaces:

AbstractActorContext, ActorContext, ActorRefFactory, Cell, Children, DeathWatch, Dispatch, FaultHandling, ReceiveTimeout, UntypedActorContext

public final class ResizablePoolCell
extends RoutedActorCell

INTERNAL API

Nested Class Summary

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

RoutedActorCell.RouterActorCreator

Constructor Summary

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

Method Summary

Pool	pool()
protected void	preSuperStart() Called when router is initalized 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, autoReceiveMessage, become, become, become, clazz, clearActorCellFields, clearActorFields, contextStack, create, currentMessage, DefaultState, dispatcher, emptyActorRefSet, emptyBehaviorStack, emptyCancellable, 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.UntypedActorContext

getChild, getChildren

Methods inherited from interface akka.actor.AbstractActorContext

getChild, getChildren

Methods inherited from interface akka.actor.ActorContext

become, child, children, receiveTimeout, setReceiveTimeout, unwatch, watch, 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.ReceiveTimeout

cancelReceiveTimeout, checkReceiveTimeout, receiveTimeout, receiveTimeoutData, setReceiveTimeout

Methods inherited from interface akka.actor.dungeon.Children

_childrenRefsDoNotCallMeDirectly, _nextNameDoNotCallMeDirectly, actorOf, actorOf, attachChild, attachChild, checkName, child, children, childrenRefs, getAllChildStats, getChild, getChildByName, getChildByRef, getChildren, getSingleChild, initChild, isNormal, isTerminating, makeChild, randomName, removeChildAndGetStateChange, reserveChild, resumeChildren, setChildrenTerminationReason, setTerminated, stop, suspendChildren, swapChildrenRefs, unreserveChild, waitingForChildrenOrNull

Methods inherited from interface akka.actor.dungeon.Dispatch

_mailboxDoNotCallMeDirectly, handleException, hasMessages, init, isTerminated, mailbox, numberOfMessages, restart, resume, sendSystemMessage, stop, suspend, swapMailbox

Methods inherited from interface akka.actor.dungeon.DeathWatch

addressTerminated, addWatcher, maintainAddressTerminatedSubscription, receivedTerminated, removeFromSet, remWatcher, subscribeAddressTerminated, tellWatchersWeDied, terminatedQueued, terminatedQueuedFor, unsubscribeAddressTerminated, unwatch, unwatchWatchedActors, watch, watchedActorTerminated, watchedBy, watching, watchingContains

Methods inherited from interface akka.actor.dungeon.FaultHandling

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

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()

resizer

public Resizer resizer()

preSuperStart

protected void preSuperStart()

Description copied from class: RoutedActorCell

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

Overrides:

preSuperStart in class RoutedActorCell

sendMessage

public void sendMessage(Envelope envelope)

Description copied from class: RoutedActorCell

Route the message via the router to the selected destination.

When CurrentRoutees is sent to the RoutedActorRef it replies with RouterRoutees.

Specified by:

sendMessage in interface Cell

Specified by:

sendMessage in interface Dispatch

Overrides:

sendMessage in class RoutedActorCell

Parameters:

envelope - (undocumented)

resize

public void resize(boolean initial)