|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| 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()
RoutedActorCellrouter is initalized but before super.start() to
be able to do extra initialization in subclass.
preSuperStart in class RoutedActorCellpublic void sendMessage(Envelope envelope)
RoutedActorCell
When CurrentRoutees is sent to the RoutedActorRef it
replies with RouterRoutees.
sendMessage in interface CellsendMessage in interface DispatchsendMessage in class RoutedActorCellenvelope - (undocumented)public void resize(boolean initial)
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||