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 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<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<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(String role)
DistributedPubSubSettings	withRole(scala.Option<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 Details

DistributedPubSubSettings

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

Method Details

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<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(String role)

withRole

public DistributedPubSubSettings withRole(scala.Option<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)