Package akka.stream

Class ActorAttributes


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

      • ActorAttributes

        public ActorAttributes()
    • Method Detail

      • dispatcher

        public static 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 static 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 static 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 static 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 static 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 static 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)