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, writeObject
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, sendMessage, setActorFields, splitNameAndUid, stash, SuspendedState, SuspendedWaitForChildrenState, system, systemImpl, systemInvoke, terminatedProps, uid, unbecome, undefinedUid, unwatch, watch
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChild, getChildren
getChild, getChildren
become, child, children, receiveTimeout, setReceiveTimeout, unwatch, watch, writeObject
actorFor, actorFor, actorFor, actorFor, actorOf, actorOf, actorSelection, actorSelection, stop
childrenRefs, getChildByName, getSingleChild, hasMessages, isTerminated, numberOfMessages, restart, resume, sendMessage, sendSystemMessage, stop, suspend
cancelReceiveTimeout, checkReceiveTimeout, receiveTimeout, setReceiveTimeout
actorOf, 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, waitingForChildrenOrNull
handleException, hasMessages, init, initWithFailure, isTerminated, mailbox, numberOfMessages, restart, resume, sendSystemMessage, stop, suspend, swapMailbox
addressTerminated, addWatcher, isWatching, maintainAddressTerminatedSubscription, receivedTerminated, removeFromSet, remWatcher, subscribeAddressTerminated, tellWatchersWeDied, terminatedQueuedFor, unsubscribeAddressTerminated, unwatch, unwatchWatchedActors, watch, watchedActorTerminated, watchingContains
clearFailed, faultCreate, faultRecreate, faultResume, faultSuspend, finishCreate, finishRecreate, finishTerminate, handleChildTerminated, handleFailure, handleInvokeFailure, handleNonFatalOrInterruptedException, isFailed, perpetrator, resumeNonRecursive, setFailed, suspendNonRecursive, terminate
public ResizablePoolCell(ActorSystemImpl _system, InternalActorRef _ref, Props _routerProps, MessageDispatcher _routerDispatcher, Props _routeeProps, InternalActorRef _supervisor, Pool pool)
public Pool pool()
public Resizer resizer()
protected void preSuperStart()
RoutedActorCell
router
is initialized but before super.start()
to
be able to do extra initialization in subclass.preSuperStart
in class RoutedActorCell
public void sendMessage(Envelope envelope)
RoutedActorCell
sendMessage
in interface Cell
sendMessage
in interface Dispatch
sendMessage
in class RoutedActorCell
envelope
- (undocumented)public void resize(boolean initial)