public class Supervision
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
Supervision.Directive |
static class |
Supervision.Restart$
Scala API: The element is dropped and the stream continues after restarting the stage
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 and Description |
---|
Supervision() |
Modifier and Type | Method and 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 stage
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. |
public static Supervision.Stop$ stop()
public static Supervision.Resume$ resume()
public static Supervision.Restart$ restart()
public static scala.Function1<java.lang.Throwable,Supervision.Directive> stoppingDecider()
Decider
that returns Stop
for all exceptions.public static Function<java.lang.Throwable,Supervision.Directive> getStoppingDecider()
stop()
for all exceptions.public static scala.Function1<java.lang.Throwable,Supervision.Directive> resumingDecider()
Decider
that returns Resume
for all exceptions.public static Function<java.lang.Throwable,Supervision.Directive> getResumingDecider()
resume()
for all exceptions.public static scala.Function1<java.lang.Throwable,Supervision.Directive> restartingDecider()
Decider
that returns Restart
for all exceptions.public static Function<java.lang.Throwable,Supervision.Directive> getRestartingDecider()
restart()
for all exceptions.