Package org.apache.pekko.stream

Class Supervision

java.lang.Object

org.apache.pekko.stream.Supervision

public class Supervision
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Supervision.Directive
static class	Supervision.Restart$	Scala API: The element is dropped and the stream continues after restarting the operator if application code for processing an element throws an exception.
static class	Supervision.Resume$	Scala API: The element is dropped and the stream continues if application code for processing an element throws an exception.
static class	Supervision.Stop$	Scala API: The stream will be completed with failure if application code for processing an element throws an exception.

Constructor Summary

Constructors

Constructor	Description
Supervision()

Method Summary

Modifier and Type	Method	Description
static Function<java.lang.Throwable,Supervision.Directive>	getRestartingDecider()	Java API: Decider function that returns restart() for all exceptions.
static Function<java.lang.Throwable,Supervision.Directive>	getResumingDecider()	Java API: Decider function that returns resume() for all exceptions.
static Function<java.lang.Throwable,Supervision.Directive>	getStoppingDecider()	Java API: Decider function that returns stop() for all exceptions.
static Supervision.Restart$	restart()	Java API: The element is dropped and the stream continues after restarting the operator if application code for processing an element throws an exception.
static scala.Function1<java.lang.Throwable,Supervision.Directive>	restartingDecider()	Scala API: Decider that returns Restart for all exceptions.
static Supervision.Resume$	resume()	Java API: The element is dropped and the stream continues if application code for processing an element throws an exception.
static scala.Function1<java.lang.Throwable,Supervision.Directive>	resumingDecider()	Scala API: Decider that returns Resume for all exceptions.
static Supervision.Stop$	stop()	Java API: The stream will be completed with failure if application code for processing an element throws an exception.
static scala.Function1<java.lang.Throwable,Supervision.Directive>	stoppingDecider()	Scala API: Decider that returns Stop for all exceptions.

Methods inherited from class java.lang.Object

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

Constructor Detail

Supervision

public Supervision()

Method Detail

stop

public static Supervision.Stop$ stop()

Java API: The stream will be completed with failure if application code for processing an element throws an exception.

resume

public static Supervision.Resume$ resume()

Java API: The element is dropped and the stream continues if application code for processing an element throws an exception.

restart

public static Supervision.Restart$ restart()

Java API: The element is dropped and the stream continues after restarting the operator if application code for processing an element throws an exception. Restarting an operator means that any accumulated state is cleared. This is typically performed by creating a new instance of the operator.

stoppingDecider

public static scala.Function1<java.lang.Throwable,Supervision.Directive> stoppingDecider()

Scala API: Decider that returns Stop for all exceptions.

getStoppingDecider

public static Function<java.lang.Throwable,Supervision.Directive> getStoppingDecider()

Java API: Decider function that returns stop() for all exceptions.

resumingDecider

public static scala.Function1<java.lang.Throwable,Supervision.Directive> resumingDecider()

Scala API: Decider that returns Resume for all exceptions.

getResumingDecider

public static Function<java.lang.Throwable,Supervision.Directive> getResumingDecider()

Java API: Decider function that returns resume() for all exceptions.

restartingDecider

public static scala.Function1<java.lang.Throwable,Supervision.Directive> restartingDecider()

Scala API: Decider that returns Restart for all exceptions.

getRestartingDecider

public static Function<java.lang.Throwable,Supervision.Directive> getRestartingDecider()

Java API: Decider function that returns restart() for all exceptions.