Package org.apache.pekko.stream
Class Supervision
java.lang.Object
org.apache.pekko.stream.Supervision
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interface
static class
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
Scala API: The element is dropped and the stream continues if application code for processing an element throws an exception.static class
Scala API: The stream will be completed with failure if application code for processing an element throws an exception. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic Function<Throwable,
Supervision.Directive> Java API: Decider function that returnsrestart()
for all exceptions.static Function<Throwable,
Supervision.Directive> Java API: Decider function that returnsresume()
for all exceptions.static Function<Throwable,
Supervision.Directive> Java API: Decider function that returnsstop()
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<Throwable,
Supervision.Directive> Scala API:Decider
that returnsRestart
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<Throwable,
Supervision.Directive> Scala API:Decider
that returnsResume
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<Throwable,
Supervision.Directive> Scala API:Decider
that returnsStop
for all exceptions.
-
Constructor Details
-
Supervision
public Supervision()
-
-
Method Details
-
stop
Java API: The stream will be completed with failure if application code for processing an element throws an exception. -
resume
Java API: The element is dropped and the stream continues if application code for processing an element throws an exception. -
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
Scala API:Decider
that returnsStop
for all exceptions. -
getStoppingDecider
Java API: Decider function that returnsstop()
for all exceptions. -
resumingDecider
Scala API:Decider
that returnsResume
for all exceptions. -
getResumingDecider
Java API: Decider function that returnsresume()
for all exceptions. -
restartingDecider
Scala API:Decider
that returnsRestart
for all exceptions. -
getRestartingDecider
Java API: Decider function that returnsrestart()
for all exceptions.
-