Package akka.stream

Class ActorAttributes


  • public class ActorAttributes
    extends java.lang.Object
    Attributes for the Materializer. 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)
      • 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)
      • debugLogging

        public static Attributes debugLogging​(boolean enabled)
        Enables additional low level troubleshooting logging at DEBUG log level
        Parameters:
        enabled - (undocumented)
        Returns:
        (undocumented)
      • streamSubscriptionTimeout

        public static Attributes streamSubscriptionTimeout​(scala.concurrent.duration.FiniteDuration timeout,
                                                           StreamSubscriptionTimeoutTerminationMode mode)
        Scala API: Defines a timeout for stream subscription and what action to take when that hits.
        Parameters:
        timeout - (undocumented)
        mode - (undocumented)
        Returns:
        (undocumented)
      • streamSubscriptionTimeout

        public static Attributes streamSubscriptionTimeout​(java.time.Duration timeout,
                                                           StreamSubscriptionTimeoutTerminationMode mode)
        Java API: Defines a timeout for stream subscription and what action to take when that hits.
        Parameters:
        timeout - (undocumented)
        mode - (undocumented)
        Returns:
        (undocumented)
      • outputBurstLimit

        public static Attributes outputBurstLimit​(int limit)
        Maximum number of elements emitted in batch if downstream signals large demand.
        Parameters:
        limit - (undocumented)
        Returns:
        (undocumented)
      • fuzzingMode

        public static Attributes fuzzingMode​(boolean enabled)
        Test utility: fuzzing mode means that GraphStage events are not processed in FIFO order within a fused subgraph, but randomized.
        Parameters:
        enabled - (undocumented)
        Returns:
        (undocumented)
      • maxFixedBufferSize

        public static Attributes maxFixedBufferSize​(int size)
        Configure the maximum buffer size for which a FixedSizeBuffer will be preallocated. This defaults to a large value because it is usually better to fail early when system memory is not sufficient to hold the buffer.
        Parameters:
        size - (undocumented)
        Returns:
        (undocumented)
      • syncProcessingLimit

        public static Attributes syncProcessingLimit​(int limit)
        Limit for number of messages that can be processed synchronously in stream to substream communication
        Parameters:
        limit - (undocumented)
        Returns:
        (undocumented)