akka.cluster.pubsub

Class DistributedPubSubSettings

java.lang.Object

akka.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.

Constructor Summary

Constructors

Constructor and Description
DistributedPubSubSettings(scala.Option<java.lang.String> role, RoutingLogic routingLogic, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration removedTimeToLive, int maxDeltaElements)

Method Summary

Modifier and Type	Method and Description
static DistributedPubSubSettings	apply(ActorSystem system) Create settings from the default configuration akka.cluster.pub-sub.
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.
static DistributedPubSubSettings	create(ActorSystem system) Java API: Create settings from the default configuration akka.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 akka.cluster.pub-sub.
scala.concurrent.duration.FiniteDuration	gossipInterval()
int	maxDeltaElements()
scala.concurrent.duration.FiniteDuration	removedTimeToLive()
scala.Option<java.lang.String>	role()
static scala.Option<java.lang.String>	roleOption(java.lang.String role) INTERNAL API
RoutingLogic	routingLogic()
DistributedPubSubSettings	withGossipInterval(scala.concurrent.duration.FiniteDuration gossipInterval)
DistributedPubSubSettings	withMaxDeltaElements(int maxDeltaElements)
DistributedPubSubSettings	withRemovedTimeToLive(scala.concurrent.duration.FiniteDuration removedTimeToLive)
DistributedPubSubSettings	withRole(scala.Option<java.lang.String> role)
DistributedPubSubSettings	withRole(java.lang.String role)
DistributedPubSubSettings	withRoutingLogic(RoutingLogic routingLogic)

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)

Method Detail

apply

public static DistributedPubSubSettings apply(ActorSystem system)

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

Parameters:

system - (undocumented)

Returns:

(undocumented)

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

routingLogic

public RoutingLogic routingLogic()

gossipInterval

public scala.concurrent.duration.FiniteDuration gossipInterval()

removedTimeToLive

public scala.concurrent.duration.FiniteDuration removedTimeToLive()

maxDeltaElements

public int maxDeltaElements()

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)