Class DistributedPubSubSettings

  • All Implemented Interfaces:
    NoSerializationVerificationNeeded

    public final class DistributedPubSubSettings
    extends java.lang.Object
    implements NoSerializationVerificationNeeded
    param: role Start the mediator on members tagged with this role. All members are used if undefined. param: routingLogic The routing logic to use for Send. param: gossipInterval How often the DistributedPubSubMediator should send out gossip information param: removedTimeToLive Removed entries are pruned after this duration param: maxDeltaElements Maximum number of elements to transfer in one message when synchronizing the registries. Next chunk will be transferred in next round of gossip. param: sendToDeadLettersWhenNoSubscribers When a message is published to a topic with no subscribers send it to the dead letters.
    • Constructor Detail

      • DistributedPubSubSettings

        public DistributedPubSubSettings​(scala.Option<java.lang.String> role,
                                         RoutingLogic routingLogic,
                                         scala.concurrent.duration.FiniteDuration gossipInterval,
                                         scala.concurrent.duration.FiniteDuration removedTimeToLive,
                                         int maxDeltaElements,
                                         boolean sendToDeadLettersWhenNoSubscribers)
      • DistributedPubSubSettings

        public DistributedPubSubSettings​(scala.Option<java.lang.String> role,
                                         RoutingLogic routingLogic,
                                         scala.concurrent.duration.FiniteDuration gossipInterval,
                                         scala.concurrent.duration.FiniteDuration removedTimeToLive,
                                         int maxDeltaElements)
        Deprecated.
        Use the other constructor instead. Since 2.5.5.
    • Method Detail

      • apply

        public static DistributedPubSubSettings apply​(com.typesafe.config.Config config)
        Create settings from a configuration with the same layout as the default configuration akka.cluster.pub-sub.
        Parameters:
        config - (undocumented)
        Returns:
        (undocumented)
      • create

        public static DistributedPubSubSettings create​(ActorSystem system)
        Java API: Create settings from the default configuration akka.cluster.pub-sub.
        Parameters:
        system - (undocumented)
        Returns:
        (undocumented)
      • create

        public static DistributedPubSubSettings create​(com.typesafe.config.Config config)
        Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.pub-sub.
        Parameters:
        config - (undocumented)
        Returns:
        (undocumented)
      • roleOption

        public static scala.Option<java.lang.String> roleOption​(java.lang.String role)
        INTERNAL API
        Parameters:
        role - (undocumented)
        Returns:
        (undocumented)
      • role

        public scala.Option<java.lang.String> role()
      • gossipInterval

        public scala.concurrent.duration.FiniteDuration gossipInterval()
      • removedTimeToLive

        public scala.concurrent.duration.FiniteDuration removedTimeToLive()
      • maxDeltaElements

        public int maxDeltaElements()
      • sendToDeadLettersWhenNoSubscribers

        public boolean sendToDeadLettersWhenNoSubscribers()
      • withGossipInterval

        public DistributedPubSubSettings withGossipInterval​(scala.concurrent.duration.FiniteDuration gossipInterval)
      • withRemovedTimeToLive

        public DistributedPubSubSettings withRemovedTimeToLive​(scala.concurrent.duration.FiniteDuration removedTimeToLive)
      • withSendToDeadLettersWhenNoSubscribers

        public DistributedPubSubSettings withSendToDeadLettersWhenNoSubscribers​(boolean sendToDeadLetterWhenNoSubscribers)