Package akka.routing
Class ResizablePoolCell
- java.lang.Object
-
- akka.actor.ActorCell
-
- akka.routing.RoutedActorCell
-
- akka.routing.ResizablePoolCell
-
- All Implemented Interfaces:
AbstractActor.ActorContext
,ActorContext
,ActorRefFactory
,Cell
,ClassicActorContextProvider
,Children
,DeathWatch
,Dispatch
,FaultHandling
,ReceiveTimeout
,UntypedActorContext
public final class ResizablePoolCell extends RoutedActorCell
This approach is chosen for binary compatibility
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.routing.RoutedActorCell
RoutedActorCell.RouterActorCreator
-
-
Constructor Summary
Constructors Constructor Description ResizablePoolCell(ActorSystemImpl _system, InternalActorRef _ref, Props _routerProps, MessageDispatcher _routerDispatcher, Props _routeeProps, InternalActorRef _supervisor, Pool pool)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Pool
pool()
protected void
preSuperStart()
Called whenrouter
is initialized but beforesuper.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, actor_$eq, autoReceiveMessage, become, become, become, become$default$2, classicActorContext, clazz, clearActorCellFields, clearActorFields, contextStack, create, currentMessage, currentMessage_$eq, DefaultState, dispatcher, emptyActorRefSet, emptyBehaviorStack, emptyCancellable, getDispatcher, getParent, getProps, getSelf, getSystem, 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.AbstractActor.ActorContext
become, become, cancelReceiveTimeout, findChild, getChild, getChildren, getReceiveTimeout, getSender, setReceiveTimeout
-
Methods inherited from interface akka.actor.ActorContext
become, child, children, receiveTimeout, setReceiveTimeout, unwatch, watch, watchWith, 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.Children
_childrenRefsDoNotCallMeDirectly_$eq, _functionRefsDoNotCallMeDirectly_$eq, _nextNameDoNotCallMeDirectly_$eq, actorOf, actorOf, addFunctionRef, addFunctionRef$default$2, attachChild, attachChild, checkName, child, children, childrenRefs, findChild, functionRefs, getAllChildStats, getChild, getChildByName, getChildByRef, getChildren, getFunctionRefOrNobody, getFunctionRefOrNobody$default$2, getSingleChild, initChild, isNormal, isTerminating, makeChild, randomName, randomName, removeChildAndGetStateChange, removeFunctionRef, reserveChild, resumeChildren, setChildrenTerminationReason, setTerminated, stop, stopFunctionRefs, suspendChildren, suspendChildren$default$1, swapChildrenRefs, unreserveChild, waitingForChildrenOrNull
-
Methods inherited from interface akka.actor.dungeon.DeathWatch
addressTerminated, addWatcher, checkWatchingSame, isWatching, maintainAddressTerminatedSubscription, maintainAddressTerminatedSubscription$default$1, receivedTerminated, removeFromMap, remWatcher, subscribeAddressTerminated, tellWatchersWeDied, terminatedQueued_$eq, terminatedQueuedFor, unsubscribeAddressTerminated, unwatch, unwatchWatchedActors, updateWatching, watch, watchedActorTerminated, watchedBy_$eq, watching_$eq, watchingContains, watchingGet, watchWith
-
Methods inherited from interface akka.actor.dungeon.Dispatch
_mailboxDoNotCallMeDirectly_$eq, handleException, hasMessages, init, initWithFailure, isTerminated, mailbox, numberOfMessages, restart, resume, sendSystemMessage, serializeAndDeserialize, serializeAndDeserializePayload, stop, suspend, swapMailbox
-
Methods inherited from interface akka.actor.dungeon.FaultHandling
_failed_$eq, clearFailed, faultCreate, faultRecreate, faultResume, faultSuspend, finishCreate, finishRecreate, finishTerminate, handleChildTerminated, handleFailure, handleInvokeFailure, handleNonFatalOrInterruptedException, isFailed, perpetrator, resumeNonRecursive, setFailed, suspendNonRecursive, terminate
-
Methods inherited from interface akka.actor.dungeon.ReceiveTimeout
cancelReceiveTimeout, checkReceiveTimeout, checkReceiveTimeout$default$1, receiveTimeout, receiveTimeoutData_$eq, rescheduleReceiveTimeout, setReceiveTimeout
-
Methods inherited from interface akka.actor.UntypedActorContext
getChild, getChildren
-
-
-
-
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()
-
preSuperStart
protected void preSuperStart()
Description copied from class:RoutedActorCell
Called whenrouter
is initialized but beforesuper.start()
to be able to do extra initialization in subclass.- Overrides:
preSuperStart
in classRoutedActorCell
-
resize
public void resize(boolean initial)
-
resizer
public Resizer resizer()
-
sendMessage
public void sendMessage(Envelope envelope)
Description copied from class:RoutedActorCell
Route the message via the router to the selected destination.- Specified by:
sendMessage
in interfaceCell
- Specified by:
sendMessage
in interfaceDispatch
- Overrides:
sendMessage
in classRoutedActorCell
- Parameters:
envelope
- (undocumented)
-
-