Package org.apache.pekko.cluster.sharding.typed

Class ReplicatedEntity<M>

  • public final class ReplicatedEntity<M>
extends java.lang.Object
    Settings for a specific replica id in replicated sharding Currently only Entity's with ShardingEnvelope are supported but this may change in the future

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static <M> ReplicatedEntity<M> apply​(ReplicaId replicaId, Entity<M,​ShardingEnvelope<M>> entity)
      Scala API: Defines the pekko.cluster.sharding.typed.scaladsl.Entity to use for a given replica, note that the behavior can be a behavior created with pekko.persistence.typed.scaladsl.ReplicatedEventSourcing or an arbitrary non persistent pekko.actor.typed.Behavior but must never be a regular pekko.persistence.typed.scaladsl.EventSourcedBehavior as that requires a single writer and that would cause it to have multiple writers.
      static <M> ReplicatedEntity<M> create​(ReplicaId replicaId, Entity<M,​ShardingEnvelope<M>> entity)
      Java API: Defines the pekko.cluster.sharding.typed.javadsl.Entity to use for a given replica, note that the behavior can be a pekko.persistence.typed.javadsl.ReplicatedEventSourcedBehavior or an arbitrary non persistent pekko.actor.typed.Behavior but must never be a regular pekko.persistence.typed.javadsl.EventSourcedBehavior as that requires a single writer and that would cause it to have multiple writers.
      Entity<M,​ShardingEnvelope<M>> entity()  
      ReplicaId replicaId()  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • ReplicatedEntity

        public ReplicatedEntity()

    • Method Detail

      • create

        public static <M> ReplicatedEntity<M> create​(ReplicaId replicaId,
                                             Entity<M,​ShardingEnvelope<M>> entity)
        Java API: Defines the pekko.cluster.sharding.typed.javadsl.Entity to use for a given replica, note that the behavior can be a pekko.persistence.typed.javadsl.ReplicatedEventSourcedBehavior or an arbitrary non persistent pekko.actor.typed.Behavior but must never be a regular pekko.persistence.typed.javadsl.EventSourcedBehavior as that requires a single writer and that would cause it to have multiple writers.

      • apply

        public static <M> ReplicatedEntity<M> apply​(ReplicaId replicaId,
                                            Entity<M,​ShardingEnvelope<M>> entity)
        Scala API: Defines the pekko.cluster.sharding.typed.scaladsl.Entity to use for a given replica, note that the behavior can be a behavior created with pekko.persistence.typed.scaladsl.ReplicatedEventSourcing or an arbitrary non persistent pekko.actor.typed.Behavior but must never be a regular pekko.persistence.typed.scaladsl.EventSourcedBehavior as that requires a single writer and that would cause it to have multiple writers.