Package akka.cluster.sharding.internal
Class DDataRememberEntitiesShardStore
- java.lang.Object
-
- akka.cluster.sharding.internal.DDataRememberEntitiesShardStore
-
- All Implemented Interfaces:
Actor
,ActorLogging
,Stash
,StashSupport
,UnrestrictedStash
,RequiresMessageQueue<DequeBasedMessageQueueSemantics>
public final class DDataRememberEntitiesShardStore extends java.lang.Object implements Actor, Stash, ActorLogging
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
DDataRememberEntitiesShardStore.Evt
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description DDataRememberEntitiesShardStore(java.lang.String shardId, java.lang.String typeName, ClusterShardingSettings settings, ActorRef replicator, int majorityMinCap)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Scala API: Stores the context for this actor, including self, and sender.protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.protected void
akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.scala.concurrent.ExecutionContext
ec()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
idle()
DequeBasedMessageQueueSemantics
mailbox()
Cluster
node()
static Props
props(java.lang.String shardId, java.lang.String typeName, ClusterShardingSettings settings, ActorRef replicator, int majorityMinCap)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.ActorRef
self()
The 'self' field holds the ActorRef for this actor.SelfUniqueAddress
selfUniqueAddress()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
waitingForAllEntityIds(scala.collection.immutable.Set<java.lang.Object> gotKeys, scala.collection.immutable.Set<java.lang.String> ids, scala.Option<ActorRef> shardWaiting)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preStart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.actor.StashSupport
actorCell, clearStash, enqueueFirst, prepend, stash, theStash_$eq, unstash, unstashAll, unstashAll
-
Methods inherited from interface akka.actor.UnrestrictedStash
postStop, preRestart, super$postStop, super$preRestart
-
-
-
-
Constructor Detail
-
DDataRememberEntitiesShardStore
public DDataRememberEntitiesShardStore(java.lang.String shardId, java.lang.String typeName, ClusterShardingSettings settings, ActorRef replicator, int majorityMinCap)
-
-
Method Detail
-
props
public static Props props(java.lang.String shardId, java.lang.String typeName, ClusterShardingSettings settings, ActorRef replicator, int majorityMinCap)
-
mailbox
public DequeBasedMessageQueueSemantics mailbox()
- Specified by:
mailbox
in interfaceStashSupport
-
akka$actor$StashSupport$_setter_$mailbox_$eq
protected void akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
- Specified by:
akka$actor$StashSupport$_setter_$mailbox_$eq
in interfaceStashSupport
-
context
public ActorContext context()
Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API.getContext
returns aAbstractActor.ActorContext
, which is the Java API of the actor context.- Specified by:
context
in interfaceActor
- Specified by:
context
in interfaceStashSupport
-
self
public final ActorRef self()
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
self
in interfaceActor
- Specified by:
self
in interfaceStashSupport
-
akka$actor$Actor$_setter_$context_$eq
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API.getContext
returns aAbstractActor.ActorContext
, which is the Java API of the actor context.- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
akka$actor$Actor$_setter_$self_$eq
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
akka$actor$Actor$_setter_$self_$eq
in interfaceActor
-
ec
public scala.concurrent.ExecutionContext ec()
-
node
public Cluster node()
-
selfUniqueAddress
public SelfUniqueAddress selfUniqueAddress()
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
-
idle
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> idle()
-
waitingForAllEntityIds
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForAllEntityIds(scala.collection.immutable.Set<java.lang.Object> gotKeys, scala.collection.immutable.Set<java.lang.String> ids, scala.Option<ActorRef> shardWaiting)
-
-