Package org.apache.pekko.pattern

Class BackoffOptionsImpl

java.lang.Object

org.apache.pekko.pattern.BackoffOptionsImpl

All Implemented Interfaces:

java.io.Serializable, BackoffOptions, scala.Equals, scala.Product

public final class BackoffOptionsImpl
extends java.lang.Object
implements BackoffOptions, scala.Product, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor

Description

BackoffOptionsImpl(BackoffType backoffType, Props childProps, java.lang.String childName, scala.concurrent.duration.FiniteDuration minBackoff, scala.concurrent.duration.FiniteDuration maxBackoff, double randomFactor, scala.Option<BackoffReset> reset, OneForOneStrategy supervisorStrategy, scala.Option<java.lang.Object> replyWhileStopped, scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> finalStopMessage)

Method Summary

Modifier and Type	Method	Description
static BackoffType	$lessinit$greater$default$1()
static scala.Option<scala.Function1<java.lang.Object,java.lang.Object>>	$lessinit$greater$default$10()
static scala.Option<BackoffReset>	$lessinit$greater$default$7()
static OneForOneStrategy	$lessinit$greater$default$8()
static scala.Option<java.lang.Object>	$lessinit$greater$default$9()
static BackoffOptionsImpl	apply(BackoffType backoffType, Props childProps, java.lang.String childName, scala.concurrent.duration.FiniteDuration minBackoff, scala.concurrent.duration.FiniteDuration maxBackoff, double randomFactor, scala.Option<BackoffReset> reset, OneForOneStrategy supervisorStrategy, scala.Option<java.lang.Object> replyWhileStopped, scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> finalStopMessage)
static BackoffType	apply$default$1()
static scala.Option<scala.Function1<java.lang.Object,java.lang.Object>>	apply$default$10()
static scala.Option<BackoffReset>	apply$default$7()
static OneForOneStrategy	apply$default$8()
static scala.Option<java.lang.Object>	apply$default$9()
BackoffReset	backoffReset()
BackoffType	backoffType()
boolean	canEqual(java.lang.Object x$1)
java.lang.String	childName()
Props	childProps()
BackoffOptionsImpl	copy(BackoffType backoffType, Props childProps, java.lang.String childName, scala.concurrent.duration.FiniteDuration minBackoff, scala.concurrent.duration.FiniteDuration maxBackoff, double randomFactor, scala.Option<BackoffReset> reset, OneForOneStrategy supervisorStrategy, scala.Option<java.lang.Object> replyWhileStopped, scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> finalStopMessage)
BackoffType	copy$default$1()
scala.Option<scala.Function1<java.lang.Object,java.lang.Object>>	copy$default$10()
Props	copy$default$2()
java.lang.String	copy$default$3()
scala.concurrent.duration.FiniteDuration	copy$default$4()
scala.concurrent.duration.FiniteDuration	copy$default$5()
double	copy$default$6()
scala.Option<BackoffReset>	copy$default$7()
OneForOneStrategy	copy$default$8()
scala.Option<java.lang.Object>	copy$default$9()
boolean	equals(java.lang.Object x$1)
scala.Option<scala.Function1<java.lang.Object,java.lang.Object>>	finalStopMessage()
int	hashCode()
scala.concurrent.duration.FiniteDuration	maxBackoff()
scala.concurrent.duration.FiniteDuration	minBackoff()
int	productArity()
java.lang.Object	productElement(int x$1)
java.lang.String	productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
Props	props()	Returns the props to create the back-off supervisor.
double	randomFactor()
scala.Option<java.lang.Object>	replyWhileStopped()
scala.Option<BackoffReset>	reset()
OneForOneStrategy	supervisorStrategy()
java.lang.String	toString()
static scala.Option<scala.Tuple10<BackoffType,Props,java.lang.String,scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration,java.lang.Object,scala.Option<BackoffReset>,OneForOneStrategy,scala.Option<java.lang.Object>,scala.Option<scala.Function1<java.lang.Object,java.lang.Object>>>>	unapply(BackoffOptionsImpl x$0)
BackoffOptionsImpl	withAutoReset(scala.concurrent.duration.FiniteDuration resetBackoff)
BackoffOptionsImpl	withDefaultStoppingStrategy()
BackoffOptionsImpl	withFinalStopMessage(scala.Function1<java.lang.Object,java.lang.Object> action)
BackoffOptionsImpl	withManualReset()
BackoffOptionsImpl	withMaxNrOfRetries(int maxNrOfRetries)
BackoffOptionsImpl	withReplyWhileStopped(java.lang.Object replyWhileStopped)
BackoffOptionsImpl	withSupervisorStrategy(OneForOneStrategy supervisorStrategy)

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productElementNames

Constructor Detail

BackoffOptionsImpl

public BackoffOptionsImpl(BackoffType backoffType,
                          Props childProps,
                          java.lang.String childName,
                          scala.concurrent.duration.FiniteDuration minBackoff,
                          scala.concurrent.duration.FiniteDuration maxBackoff,
                          double randomFactor,
                          scala.Option<BackoffReset> reset,
                          OneForOneStrategy supervisorStrategy,
                          scala.Option<java.lang.Object> replyWhileStopped,
                          scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> finalStopMessage)

Method Detail

$lessinit$greater$default$1

public static BackoffType $lessinit$greater$default$1()

$lessinit$greater$default$7

public static scala.Option<BackoffReset> $lessinit$greater$default$7()

$lessinit$greater$default$8

public static OneForOneStrategy $lessinit$greater$default$8()

$lessinit$greater$default$9

public static scala.Option<java.lang.Object> $lessinit$greater$default$9()

$lessinit$greater$default$10

public static scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> $lessinit$greater$default$10()

apply

public static BackoffOptionsImpl apply(BackoffType backoffType,
                                       Props childProps,
                                       java.lang.String childName,
                                       scala.concurrent.duration.FiniteDuration minBackoff,
                                       scala.concurrent.duration.FiniteDuration maxBackoff,
                                       double randomFactor,
                                       scala.Option<BackoffReset> reset,
                                       OneForOneStrategy supervisorStrategy,
                                       scala.Option<java.lang.Object> replyWhileStopped,
                                       scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> finalStopMessage)

apply$default$1

public static BackoffType apply$default$1()

apply$default$10

public static scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> apply$default$10()

apply$default$7

public static scala.Option<BackoffReset> apply$default$7()

apply$default$8

public static OneForOneStrategy apply$default$8()

apply$default$9

public static scala.Option<java.lang.Object> apply$default$9()

unapply

public static scala.Option<scala.Tuple10<BackoffType,Props,java.lang.String,scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration,java.lang.Object,scala.Option<BackoffReset>,OneForOneStrategy,scala.Option<java.lang.Object>,scala.Option<scala.Function1<java.lang.Object,java.lang.Object>>>> unapply(BackoffOptionsImpl x$0)

backoffType

public BackoffType backoffType()

childProps

public Props childProps()

childName

public java.lang.String childName()

minBackoff

public scala.concurrent.duration.FiniteDuration minBackoff()

maxBackoff

public scala.concurrent.duration.FiniteDuration maxBackoff()

randomFactor

public double randomFactor()

reset

public scala.Option<BackoffReset> reset()

supervisorStrategy

public OneForOneStrategy supervisorStrategy()

replyWhileStopped

public scala.Option<java.lang.Object> replyWhileStopped()

finalStopMessage

public scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> finalStopMessage()

backoffReset

public BackoffReset backoffReset()

withAutoReset

public BackoffOptionsImpl withAutoReset(scala.concurrent.duration.FiniteDuration resetBackoff)

Specified by:

withAutoReset in interface BackoffOptions

See Also:

ExtendedBackoffOptions.withAutoReset

withManualReset

public BackoffOptionsImpl withManualReset()

Specified by:

withManualReset in interface BackoffOptions

See Also:

ExtendedBackoffOptions.withManualReset

withSupervisorStrategy

public BackoffOptionsImpl withSupervisorStrategy(OneForOneStrategy supervisorStrategy)

Specified by:

withSupervisorStrategy in interface BackoffOptions

See Also:

ExtendedBackoffOptions.withSupervisorStrategy

withDefaultStoppingStrategy

public BackoffOptionsImpl withDefaultStoppingStrategy()

Specified by:

withDefaultStoppingStrategy in interface BackoffOptions

See Also:

ExtendedBackoffOptions.withDefaultStoppingStrategy

withReplyWhileStopped

public BackoffOptionsImpl withReplyWhileStopped(java.lang.Object replyWhileStopped)

Specified by:

withReplyWhileStopped in interface BackoffOptions

See Also:

ExtendedBackoffOptions.withReplyWhileStopped

withMaxNrOfRetries

public BackoffOptionsImpl withMaxNrOfRetries(int maxNrOfRetries)

Specified by:

withMaxNrOfRetries in interface BackoffOptions

See Also:

ExtendedBackoffOptions.withMaxNrOfRetries

withFinalStopMessage

public BackoffOptionsImpl withFinalStopMessage(scala.Function1<java.lang.Object,java.lang.Object> action)

Specified by:

withFinalStopMessage in interface BackoffOptions

See Also:

BackoffOnStopOptions.withFinalStopMessage

props

public Props props()

Description copied from interface: BackoffOptions

Returns the props to create the back-off supervisor.

Specified by:

props in interface BackoffOptions

copy

public BackoffOptionsImpl copy(BackoffType backoffType,
                               Props childProps,
                               java.lang.String childName,
                               scala.concurrent.duration.FiniteDuration minBackoff,
                               scala.concurrent.duration.FiniteDuration maxBackoff,
                               double randomFactor,
                               scala.Option<BackoffReset> reset,
                               OneForOneStrategy supervisorStrategy,
                               scala.Option<java.lang.Object> replyWhileStopped,
                               scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> finalStopMessage)

copy$default$1

public BackoffType copy$default$1()

copy$default$10

public scala.Option<scala.Function1<java.lang.Object,java.lang.Object>> copy$default$10()

copy$default$2

public Props copy$default$2()

copy$default$3

public java.lang.String copy$default$3()

copy$default$4

public scala.concurrent.duration.FiniteDuration copy$default$4()

copy$default$5

public scala.concurrent.duration.FiniteDuration copy$default$5()

copy$default$6

public double copy$default$6()

copy$default$7

public scala.Option<BackoffReset> copy$default$7()

copy$default$8

public OneForOneStrategy copy$default$8()

copy$default$9

public scala.Option<java.lang.Object> copy$default$9()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

productElementName

public java.lang.String productElementName(int x$1)

Specified by:

productElementName in interface scala.Product

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object