final class DistributedPubSubSettings extends NoSerializationVerificationNeeded

Source
DistributedPubSubMediator.scala
Linear Supertypes
NoSerializationVerificationNeeded, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DistributedPubSubSettings
  2. NoSerializationVerificationNeeded
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new DistributedPubSubSettings(role: Option[String], routingLogic: RoutingLogic, gossipInterval: FiniteDuration, removedTimeToLive: FiniteDuration, maxDeltaElements: Int, sendToDeadLettersWhenNoSubscribers: Boolean)

    role

    Start the mediator on members tagged with this role. All members are used if undefined.

    routingLogic

    The routing logic to use for Send.

    gossipInterval

    How often the DistributedPubSubMediator should send out gossip information

    removedTimeToLive

    Removed entries are pruned after this duration

    maxDeltaElements

    Maximum number of elements to transfer in one message when synchronizing the registries. Next chunk will be transferred in next round of gossip.

    sendToDeadLettersWhenNoSubscribers

    When a message is published to a topic with no subscribers send it to the dead letters.

  2. new DistributedPubSubSettings(role: Option[String], routingLogic: RoutingLogic, gossipInterval: FiniteDuration, removedTimeToLive: FiniteDuration, maxDeltaElements: Int)
    Annotations
    @deprecated
    Deprecated

    (Since version 2.5.5) Use the other constructor instead.

Value Members

  1. val gossipInterval: FiniteDuration
  2. val maxDeltaElements: Int
  3. val removedTimeToLive: FiniteDuration
  4. val role: Option[String]
  5. val routingLogic: RoutingLogic
  6. val sendToDeadLettersWhenNoSubscribers: Boolean
  7. def withGossipInterval(gossipInterval: FiniteDuration): DistributedPubSubSettings
  8. def withMaxDeltaElements(maxDeltaElements: Int): DistributedPubSubSettings
  9. def withRemovedTimeToLive(removedTimeToLive: FiniteDuration): DistributedPubSubSettings
  10. def withRole(role: Option[String]): DistributedPubSubSettings
  11. def withRole(role: String): DistributedPubSubSettings
  12. def withRoutingLogic(routingLogic: RoutingLogic): DistributedPubSubSettings
  13. def withSendToDeadLettersWhenNoSubscribers(sendToDeadLetterWhenNoSubscribers: Boolean): DistributedPubSubSettings