public final class ResizablePoolCell extends RoutedActorCell
RoutedActorCell.RouterActorCreator| Constructor and Description |
|---|
ResizablePoolCell(ActorSystemImpl _system,
InternalActorRef _ref,
Props _routerProps,
MessageDispatcher _routerDispatcher,
Props _routeeProps,
InternalActorRef _supervisor,
Pool pool) |
| Modifier and Type | Method and 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.
|
actor_$eq, actor, actorFor, actorFor, actorFor, actorFor, actorOf, actorOf, actorSelection, actorSelection, addFunctionRef, addressTerminated, addRoutee, addRoutees, addWatcher, akka$actor$dungeon$Children$$_childrenRefsDoNotCallMeDirectly_$eq, akka$actor$dungeon$Children$$_childrenRefsDoNotCallMeDirectly, akka$actor$dungeon$Children$$_functionRefsDoNotCallMeDirectly_$eq, akka$actor$dungeon$Children$$_functionRefsDoNotCallMeDirectly, akka$actor$dungeon$Children$$_nextNameDoNotCallMeDirectly_$eq, akka$actor$dungeon$Children$$_nextNameDoNotCallMeDirectly, akka$actor$dungeon$DeathWatch$$terminatedQueued_$eq, akka$actor$dungeon$DeathWatch$$terminatedQueued, akka$actor$dungeon$DeathWatch$$watchedBy_$eq, akka$actor$dungeon$DeathWatch$$watchedBy, akka$actor$dungeon$DeathWatch$$watching_$eq, akka$actor$dungeon$DeathWatch$$watching, akka$actor$dungeon$Dispatch$$_mailboxDoNotCallMeDirectly_$eq, akka$actor$dungeon$Dispatch$$_mailboxDoNotCallMeDirectly, akka$actor$dungeon$FaultHandling$$_failed_$eq, akka$actor$dungeon$FaultHandling$$_failed, akka$actor$dungeon$ReceiveTimeout$$receiveTimeoutData_$eq, akka$actor$dungeon$ReceiveTimeout$$receiveTimeoutData, attachChild, attachChild, autoReceiveMessage, become, become, become, become, become$default$2, cancelReceiveTimeout, checkReceiveTimeout, child, children, childrenRefs, clazz, clearActorCellFields, clearActorFields, create, currentMessage_$eq, currentMessage, dispatcher, faultCreate, faultRecreate, faultResume, faultSuspend, getAllChildStats, getChild, getChildByName, getChildByRef, getChildren, getFunctionRefOrNobody, getFunctionRefOrNobody$default$2, getSingleChild, guardian, handleChildTerminated, handleFailure, handleInvokeFailure, handleNonFatalOrInterruptedException, handleSupervise, hasMessages, init, initChild, initWithFailure, invoke, isLocal, isNormal, isTerminated, isTerminating, isWatching, lookupRoot, mailbox, newActor, numberOfMessages, parent, props, provider, publish, randomName, randomName, receivedTerminated, receiveMessage, receiveTimeout, removeChildAndGetStateChange, removeFunctionRef, removeRoutee, removeRoutees, remWatcher, reserveChild, restart, resume, resumeChildren, routeeProps, router, routerConfig, self, sender, sendSystemMessage, setActorFields, setChildrenTerminationReason, setReceiveTimeout, setTerminated, start, stash, stop, stop, stopFunctionRefs, suspend, suspendChildren, suspendChildren$default$1, swapMailbox, system, systemImpl, systemInvoke, tellWatchersWeDied, terminate, terminatedQueuedFor, uid, unbecome, unreserveChild, unwatchWatchedActors, waitingForChildrenOrNull, watchedActorTerminated, writeObjectactor, 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, sendMessage, setActorFields, splitNameAndUid, stash, SuspendedState, SuspendedWaitForChildrenState, system, systemImpl, systemInvoke, terminatedProps, uid, unbecome, undefinedUid, unwatch, watchclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetChild, getChildrengetChild, getChildrenbecome, child, children, receiveTimeout, setReceiveTimeout, unwatch, watch, writeObjectactorFor, actorFor, actorFor, actorFor, actorOf, actorOf, actorSelection, actorSelection, stopchildrenRefs, getChildByName, getSingleChild, hasMessages, isTerminated, numberOfMessages, restart, resume, sendMessage, sendSystemMessage, stop, suspendcancelReceiveTimeout, checkReceiveTimeout, receiveTimeout, setReceiveTimeoutactorOf, actorOf, addFunctionRef, attachChild, attachChild, checkName, child, children, childrenRefs, functionRefs, getAllChildStats, getChild, getChildByName, getChildByRef, getChildren, getFunctionRefOrNobody, getSingleChild, initChild, isNormal, isTerminating, makeChild, randomName, randomName, removeChildAndGetStateChange, removeFunctionRef, reserveChild, resumeChildren, setChildrenTerminationReason, setTerminated, stop, stopFunctionRefs, suspendChildren, swapChildrenRefs, unreserveChild, waitingForChildrenOrNullhandleException, hasMessages, init, initWithFailure, isTerminated, mailbox, numberOfMessages, restart, resume, sendSystemMessage, stop, suspend, swapMailboxaddressTerminated, addWatcher, isWatching, maintainAddressTerminatedSubscription, receivedTerminated, removeFromSet, remWatcher, subscribeAddressTerminated, tellWatchersWeDied, terminatedQueuedFor, unsubscribeAddressTerminated, unwatch, unwatchWatchedActors, watch, watchedActorTerminated, watchingContainsclearFailed, faultCreate, faultRecreate, faultResume, faultSuspend, finishCreate, finishRecreate, finishTerminate, handleChildTerminated, handleFailure, handleInvokeFailure, handleNonFatalOrInterruptedException, isFailed, perpetrator, resumeNonRecursive, setFailed, suspendNonRecursive, terminatepublic ResizablePoolCell(ActorSystemImpl _system, InternalActorRef _ref, Props _routerProps, MessageDispatcher _routerDispatcher, Props _routeeProps, InternalActorRef _supervisor, Pool pool)
public Pool pool()
public Resizer resizer()
protected void preSuperStart()
RoutedActorCellrouter is initialized but before super.start() to
be able to do extra initialization in subclass.preSuperStart in class RoutedActorCellpublic void sendMessage(Envelope envelope)
RoutedActorCellsendMessage in interface CellsendMessage in interface DispatchsendMessage in class RoutedActorCellenvelope - (undocumented)public void resize(boolean initial)