Package org.apache.pekko.cluster.pubsub

Class DistributedPubSubSettings

java.lang.Object

org.apache.pekko.cluster.pubsub.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 Summary

Constructors

Constructor	Description
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.
DistributedPubSubSettings(scala.Option<java.lang.String> role, RoutingLogic routingLogic, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration removedTimeToLive, int maxDeltaElements, boolean sendToDeadLettersWhenNoSubscribers)

Method Summary

Modifier and Type	Method	Description
static DistributedPubSubSettings	apply(com.typesafe.config.Config config)	Create settings from a configuration with the same layout as the default configuration pekko.cluster.pub-sub.
static DistributedPubSubSettings	apply(ActorSystem system)	Create settings from the default configuration pekko.cluster.pub-sub.
static DistributedPubSubSettings	create(com.typesafe.config.Config config)	Java API: Create settings from a configuration with the same layout as the default configuration pekko.cluster.pub-sub.
static DistributedPubSubSettings	create(ActorSystem system)	Java API: Create settings from the default configuration pekko.cluster.pub-sub.
scala.concurrent.duration.FiniteDuration	gossipInterval()
int	maxDeltaElements()
scala.concurrent.duration.FiniteDuration	removedTimeToLive()
scala.Option<java.lang.String>	role()
RoutingLogic	routingLogic()
boolean	sendToDeadLettersWhenNoSubscribers()
DistributedPubSubSettings	withGossipInterval(scala.concurrent.duration.FiniteDuration gossipInterval)
DistributedPubSubSettings	withMaxDeltaElements(int maxDeltaElements)
DistributedPubSubSettings	withRemovedTimeToLive(scala.concurrent.duration.FiniteDuration removedTimeToLive)
DistributedPubSubSettings	withRole(java.lang.String role)
DistributedPubSubSettings	withRole(scala.Option<java.lang.String> role)
DistributedPubSubSettings	withRoutingLogic(RoutingLogic routingLogic)
DistributedPubSubSettings	withSendToDeadLettersWhenNoSubscribers(boolean sendToDeadLetterWhenNoSubscribers)

Methods inherited from class java.lang.Object

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

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 Akka 2.5.5.

Method Detail

apply

public static DistributedPubSubSettings apply(ActorSystem system)

Create settings from the default configuration pekko.cluster.pub-sub.

apply

public static DistributedPubSubSettings apply(com.typesafe.config.Config config)

Create settings from a configuration with the same layout as the default configuration pekko.cluster.pub-sub.

create

public static DistributedPubSubSettings create(ActorSystem system)

Java API: Create settings from the default configuration pekko.cluster.pub-sub.

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 pekko.cluster.pub-sub.

role

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

routingLogic

public RoutingLogic routingLogic()

gossipInterval

public scala.concurrent.duration.FiniteDuration gossipInterval()

removedTimeToLive

public scala.concurrent.duration.FiniteDuration removedTimeToLive()

maxDeltaElements

public int maxDeltaElements()

sendToDeadLettersWhenNoSubscribers

public boolean sendToDeadLettersWhenNoSubscribers()

withRole

public DistributedPubSubSettings withRole(java.lang.String role)

withRole

public DistributedPubSubSettings withRole(scala.Option<java.lang.String> role)

withRoutingLogic

public DistributedPubSubSettings withRoutingLogic(RoutingLogic routingLogic)

withGossipInterval

public DistributedPubSubSettings withGossipInterval(scala.concurrent.duration.FiniteDuration gossipInterval)

withRemovedTimeToLive

public DistributedPubSubSettings withRemovedTimeToLive(scala.concurrent.duration.FiniteDuration removedTimeToLive)

withMaxDeltaElements

public DistributedPubSubSettings withMaxDeltaElements(int maxDeltaElements)

withSendToDeadLettersWhenNoSubscribers

public DistributedPubSubSettings withSendToDeadLettersWhenNoSubscribers(boolean sendToDeadLetterWhenNoSubscribers)