Package org.apache.pekko.stream

Class StreamSubscriptionTimeoutSettings

java.lang.Object

org.apache.pekko.stream.StreamSubscriptionTimeoutSettings

public final class StreamSubscriptionTimeoutSettings
extends java.lang.Object

Leaked publishers and subscribers are cleaned up when they are not used within a given deadline, configured by StreamSubscriptionTimeoutSettings.

Constructor Summary

Constructors

Constructor	Description
StreamSubscriptionTimeoutSettings(StreamSubscriptionTimeoutTerminationMode mode, scala.concurrent.duration.FiniteDuration timeout)

Method Summary

Modifier and Type	Method	Description
static StreamSubscriptionTimeoutSettings	apply(com.typesafe.config.Config config)	Create settings from a Config subsection (Scala).
static StreamSubscriptionTimeoutSettings	apply(StreamSubscriptionTimeoutTerminationMode mode, scala.concurrent.duration.FiniteDuration timeout)	Create settings from individual values (Scala).
static StreamSubscriptionTimeoutSettings	create(com.typesafe.config.Config config)	Create settings from a Config subsection (Java).
static StreamSubscriptionTimeoutSettings	create(StreamSubscriptionTimeoutTerminationMode mode, scala.concurrent.duration.FiniteDuration timeout)	Create settings from individual values (Java).
boolean	equals(java.lang.Object other)
StreamSubscriptionTimeoutTerminationMode	mode()	Deprecated. Use attribute 'ActorAttributes.StreamSubscriptionTimeoutMode' to read the concrete setting value.
scala.concurrent.duration.FiniteDuration	timeout()	Deprecated. Use attribute 'ActorAttributes.StreamSubscriptionTimeout' to read the concrete setting value.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamSubscriptionTimeoutSettings

public StreamSubscriptionTimeoutSettings(StreamSubscriptionTimeoutTerminationMode mode,
                                         scala.concurrent.duration.FiniteDuration timeout)

Method Detail

create

public static StreamSubscriptionTimeoutSettings create(StreamSubscriptionTimeoutTerminationMode mode,
                                                       scala.concurrent.duration.FiniteDuration timeout)

Create settings from individual values (Java).

apply

public static StreamSubscriptionTimeoutSettings apply(StreamSubscriptionTimeoutTerminationMode mode,
                                                      scala.concurrent.duration.FiniteDuration timeout)

Create settings from individual values (Scala).

create

public static StreamSubscriptionTimeoutSettings create(com.typesafe.config.Config config)

Create settings from a Config subsection (Java).

apply

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

Create settings from a Config subsection (Scala).

mode

public StreamSubscriptionTimeoutTerminationMode mode()

Deprecated.

Use attribute 'ActorAttributes.StreamSubscriptionTimeoutMode' to read the concrete setting value. Since Akka 2.6.0.

timeout

public scala.concurrent.duration.FiniteDuration timeout()

Deprecated.

Use attribute 'ActorAttributes.StreamSubscriptionTimeout' to read the concrete setting value. Since Akka 2.6.0.

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object