Package akka.stream

Class ActorAttributes$


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

      • 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

      • debugLogging

        public Attributes debugLogging​(boolean enabled)
        Enables additional low level troubleshooting logging at DEBUG log level
      • streamSubscriptionTimeout

        public 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.
      • outputBurstLimit

        public Attributes outputBurstLimit​(int limit)
        Maximum number of elements emitted in batch if downstream signals large demand.
      • fuzzingMode

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

        public 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.
      • syncProcessingLimit

        public Attributes syncProcessingLimit​(int limit)
        Limit for number of messages that can be processed synchronously in stream to substream communication