Class Supervision

java.lang.Object
org.apache.pekko.stream.Supervision

public class Supervision extends Object
  • Constructor Details

    • Supervision

      public Supervision()
  • Method Details

    • 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<Throwable,Supervision.Directive> stoppingDecider()
      Scala API: Decider that returns Stop for all exceptions.
    • getStoppingDecider

      public static Function<Throwable,Supervision.Directive> getStoppingDecider()
      Java API: Decider function that returns stop() for all exceptions.
    • resumingDecider

      public static scala.Function1<Throwable,Supervision.Directive> resumingDecider()
      Scala API: Decider that returns Resume for all exceptions.
    • getResumingDecider

      public static Function<Throwable,Supervision.Directive> getResumingDecider()
      Java API: Decider function that returns resume() for all exceptions.
    • restartingDecider

      public static scala.Function1<Throwable,Supervision.Directive> restartingDecider()
      Scala API: Decider that returns Restart for all exceptions.
    • getRestartingDecider

      public static Function<Throwable,Supervision.Directive> getRestartingDecider()
      Java API: Decider function that returns restart() for all exceptions.