Package akka.stream

Class ActorAttributes$


  • public class ActorAttributes$
    extends java.lang.Object
    Attributes for the ActorMaterializer. Note that more attributes defined in Attributes.
    • Field Detail

      • MODULE$

        public static final ActorAttributes$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • ActorAttributes$

        public ActorAttributes$()
    • Method Detail

      • dispatcher

        public Attributes dispatcher​(java.lang.String dispatcher)
        Specifies the name of the dispatcher. This also adds an async boundary.
        Parameters:
        dispatcher - (undocumented)
        Returns:
        (undocumented)
      • supervisionStrategy

        public Attributes supervisionStrategy​(scala.Function1<java.lang.Throwable,​Supervision.Directive> decider)
        Scala API: Decides how exceptions from user are to be handled.

        Operators supporting supervision strategies explicitly document that they do so. If a operator does not document support for these, it should be assumed it does not support supervision.

        Parameters:
        decider - (undocumented)
        Returns:
        (undocumented)
      • withSupervisionStrategy

        public Attributes withSupervisionStrategy​(Function<java.lang.Throwable,​Supervision.Directive> decider)
        Java API: Decides how exceptions from application code are to be handled.

        Operators supporting supervision strategies explicitly document that they do so. If a operator does not document support for these, it should be assumed it does not support supervision.

        Parameters:
        decider - (undocumented)
        Returns:
        (undocumented)
      • createLogLevels

        public Attributes createLogLevels​(Logging.LogLevel onElement,
                                          Logging.LogLevel onFinish,
                                          Logging.LogLevel onFailure)
        Java API

        Configures log() operator log-levels to be used when logging. Logging a certain operation can be completely disabled by using Attributes.logLevelOff().

        Parameters:
        onElement - (undocumented)
        onFinish - (undocumented)
        onFailure - (undocumented)
        Returns:
        (undocumented)
      • createLogLevels

        public Attributes createLogLevels​(Logging.LogLevel onElement)
        Java API

        Configures log() operator log-levels to be used when logging onElement. Logging a certain operation can be completely disabled by using Attributes.logLevelOff().

        Parameters:
        onElement - (undocumented)
        Returns:
        (undocumented)
      • logLevels

        public Attributes logLevels​(Logging.LogLevel onElement,
                                    Logging.LogLevel onFinish,
                                    Logging.LogLevel onFailure)
        Configures log() operator log-levels to be used when logging. Logging a certain operation can be completely disabled by using LogLevels.Off.

        See Attributes.createLogLevels for Java API

        Parameters:
        onElement - (undocumented)
        onFinish - (undocumented)
        onFailure - (undocumented)
        Returns:
        (undocumented)