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.
      • 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().

      • 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

      • debugLogging

        public static Attributes debugLogging​(boolean enabled)
        Enables additional low level troubleshooting logging at DEBUG log level
      • 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.
      • 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.
      • outputBurstLimit

        public static Attributes outputBurstLimit​(int limit)
        Maximum number of elements emitted in batch if downstream signals large demand.
      • 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.
      • 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.
      • syncProcessingLimit

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