|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectakka.actor.ActorCell
akka.routing.RoutedActorCell
akka.routing.ResizablePoolCell
public final class ResizablePoolCell
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 |
---|
public ResizablePoolCell(ActorSystemImpl _system, InternalActorRef _ref, Props _routerProps, MessageDispatcher _routerDispatcher, Props _routeeProps, InternalActorRef _supervisor, Pool pool)
Method Detail |
---|
public Pool pool()
public Resizer resizer()
protected void preSuperStart()
RoutedActorCell
router
is initalized but before super.start()
to
be able to do extra initialization in subclass.
preSuperStart
in class RoutedActorCell
public void sendMessage(Envelope envelope)
RoutedActorCell
When CurrentRoutees
is sent to the RoutedActorRef it
replies with RouterRoutees
.
sendMessage
in interface Cell
sendMessage
in interface Dispatch
sendMessage
in class RoutedActorCell
envelope
- (undocumented)public void resize(boolean initial)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |