Class ActorMaterializerSettings
- java.lang.Object
-
- akka.stream.ActorMaterializerSettings
-
public final class ActorMaterializerSettings extends java.lang.Object
This class describes the configurable properties of theActorMaterializer
. Please refer to thewithX
methods for descriptions of the individual settings.The constructor is not public API, use create or apply on the
ActorMaterializerSettings
companion instead.
-
-
Constructor Summary
Constructors Constructor Description ActorMaterializerSettings()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static ActorMaterializerSettings
apply(int initialInputBufferSize, int maxInputBufferSize, java.lang.String dispatcher, scala.Function1<java.lang.Throwable,Supervision.Directive> supervisionDecider, StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings, boolean debugLogging, int outputBurstLimit, boolean fuzzingMode, boolean autoFusing, int maxFixedBufferSize)
Deprecated.Use config or attributes to configure the materializer.static ActorMaterializerSettings
apply(ActorSystem system)
Deprecated.Use config or attributes to configure the materializer.static ActorMaterializerSettings
apply(com.typesafe.config.Config config)
Deprecated.Use config or attributes to configure the materializer.boolean
autoFusing()
Deprecated.No longer has any effect.java.lang.String
blockingIoDispatcher()
Deprecated.Use attribute 'ActorAttributes.BlockingIoDispatcher' to read the concrete setting value.static ActorMaterializerSettings
create(int initialInputBufferSize, int maxInputBufferSize, java.lang.String dispatcher, scala.Function1<java.lang.Throwable,Supervision.Directive> supervisionDecider, StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings, boolean debugLogging, int outputBurstLimit, boolean fuzzingMode, boolean autoFusing, int maxFixedBufferSize)
Deprecated.Use config or attributes to configure the materializer.static ActorMaterializerSettings
create(ActorSystem system)
Deprecated.Use config or attributes to configure the materializer.static ActorMaterializerSettings
create(com.typesafe.config.Config config)
Deprecated.Use config or attributes to configure the materializer.boolean
debugLogging()
Deprecated.Use attribute 'ActorAttributes.DebugLogging' to read the concrete setting value.java.lang.String
dispatcher()
Deprecated.Use attribute 'ActorAttributes.Dispatcher' to read the concrete setting value.boolean
equals(java.lang.Object other)
boolean
fuzzingMode()
Deprecated.Use attribute 'ActorAttributes.FuzzingMode' to read the concrete setting value.int
initialInputBufferSize()
Deprecated.Use attribute 'Attributes.InputBuffer' to read the concrete setting value.IOSettings
ioSettings()
int
maxFixedBufferSize()
Deprecated.Use attribute 'ActorAttributes.MaxFixedBufferSize' to read the concrete setting value.int
maxInputBufferSize()
Deprecated.Use attribute 'Attributes.InputBuffer' to read the concrete setting value.int
outputBurstLimit()
Deprecated.Use attribute 'ActorAttributes.OutputBurstLimit' to read the concrete setting value.StreamRefSettings
streamRefSettings()
StreamSubscriptionTimeoutSettings
subscriptionTimeoutSettings()
scala.Function1<java.lang.Throwable,Supervision.Directive>
supervisionDecider()
Deprecated.Use attribute 'ActorAttributes.SupervisionStrategy' to read the concrete setting value.int
syncProcessingLimit()
Deprecated.Use attribute 'ActorAttributes.SyncProcessingLimit' to read the concrete setting value.java.lang.String
toString()
ActorMaterializerSettings
withBlockingIoDispatcher(java.lang.String newBlockingIoDispatcher)
Deprecated.Use attribute 'ActorAttributes.BlockingIoDispatcher' to change setting value.ActorMaterializerSettings
withDebugLogging(boolean enable)
Deprecated.Use attribute 'ActorAttributes.DebugLogging' to change setting value.ActorMaterializerSettings
withDispatcher(java.lang.String dispatcher)
Deprecated.Use attribute 'ActorAttributes.Dispatcher' to change setting value.ActorMaterializerSettings
withFuzzing(boolean enable)
Deprecated.Use attribute 'ActorAttributes.FuzzingMode' to change setting value.ActorMaterializerSettings
withInputBuffer(int initialSize, int maxSize)
Deprecated.Use attribute 'Attributes.InputBuffer' to change setting value.ActorMaterializerSettings
withIOSettings(IOSettings ioSettings)
ActorMaterializerSettings
withMaxFixedBufferSize(int size)
Deprecated.Use attribute 'ActorAttributes.MaxFixedBufferSize' to change setting value.ActorMaterializerSettings
withOutputBurstLimit(int limit)
Deprecated.Use attribute 'ActorAttributes.OutputBurstLimit' to change setting value.ActorMaterializerSettings
withStreamRefSettings(StreamRefSettings streamRefSettings)
ActorMaterializerSettings
withSubscriptionTimeoutSettings(StreamSubscriptionTimeoutSettings settings)
Leaked publishers and subscribers are cleaned up when they are not used within a given deadline, configured byStreamSubscriptionTimeoutSettings
.ActorMaterializerSettings
withSupervisionStrategy(Function<java.lang.Throwable,Supervision.Directive> decider)
Deprecated.Use attribute 'ActorAttributes.SupervisionStrategy' to change setting value.ActorMaterializerSettings
withSupervisionStrategy(scala.Function1<java.lang.Throwable,Supervision.Directive> decider)
Deprecated.Use attribute 'ActorAttributes.supervisionStrategy' to change setting value.ActorMaterializerSettings
withSyncProcessingLimit(int limit)
Deprecated.Use attribute 'ActorAttributes.SyncProcessingLimit' to change setting value.
-
-
-
Method Detail
-
apply
public static ActorMaterializerSettings apply(int initialInputBufferSize, int maxInputBufferSize, java.lang.String dispatcher, scala.Function1<java.lang.Throwable,Supervision.Directive> supervisionDecider, StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings, boolean debugLogging, int outputBurstLimit, boolean fuzzingMode, boolean autoFusing, int maxFixedBufferSize)
Deprecated.Use config or attributes to configure the materializer. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html. Since 2.6.0.CreateActorMaterializerSettings
from individual settings (Scala).Prefer using either config for defaults or attributes for per-stream config. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html"
-
apply
public static ActorMaterializerSettings apply(ActorSystem system)
Deprecated.Use config or attributes to configure the materializer. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html. Since 2.6.0.CreateActorMaterializerSettings
from the settings of anActorSystem
(Scala).Prefer using either config for defaults or attributes for per-stream config. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html"
-
apply
public static ActorMaterializerSettings apply(com.typesafe.config.Config config)
Deprecated.Use config or attributes to configure the materializer. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html. Since 2.6.0.CreateActorMaterializerSettings
from a Config subsection (Scala).Prefer using either config for defaults or attributes for per-stream config. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html"
-
create
public static ActorMaterializerSettings create(int initialInputBufferSize, int maxInputBufferSize, java.lang.String dispatcher, scala.Function1<java.lang.Throwable,Supervision.Directive> supervisionDecider, StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings, boolean debugLogging, int outputBurstLimit, boolean fuzzingMode, boolean autoFusing, int maxFixedBufferSize)
Deprecated.Use config or attributes to configure the materializer. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html. Since 2.6.0.CreateActorMaterializerSettings
from individual settings (Java).Prefer using either config for defaults or attributes for per-stream config. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html"
-
create
public static ActorMaterializerSettings create(ActorSystem system)
Deprecated.Use config or attributes to configure the materializer. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html. Since 2.6.0.CreateActorMaterializerSettings
from the settings of anActorSystem
(Java).
-
create
public static ActorMaterializerSettings create(com.typesafe.config.Config config)
Deprecated.Use config or attributes to configure the materializer. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html. Since 2.6.0.CreateActorMaterializerSettings
from a Config subsection (Java).Prefer using either config for defaults or attributes for per-stream config. See migration guide for details https://doc.akka.io/docs/akka/2.6/project/migration-guide-2.5.x-2.6.x.html"
-
initialInputBufferSize
public int initialInputBufferSize()
Deprecated.Use attribute 'Attributes.InputBuffer' to read the concrete setting value. Since 2.6.0.
-
maxInputBufferSize
public int maxInputBufferSize()
Deprecated.Use attribute 'Attributes.InputBuffer' to read the concrete setting value. Since 2.6.0.
-
dispatcher
public java.lang.String dispatcher()
Deprecated.Use attribute 'ActorAttributes.Dispatcher' to read the concrete setting value. Since 2.6.0.
-
supervisionDecider
public scala.Function1<java.lang.Throwable,Supervision.Directive> supervisionDecider()
Deprecated.Use attribute 'ActorAttributes.SupervisionStrategy' to read the concrete setting value. Since 2.6.0.
-
subscriptionTimeoutSettings
public StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings()
-
debugLogging
public boolean debugLogging()
Deprecated.Use attribute 'ActorAttributes.DebugLogging' to read the concrete setting value. Since 2.6.0.
-
outputBurstLimit
public int outputBurstLimit()
Deprecated.Use attribute 'ActorAttributes.OutputBurstLimit' to read the concrete setting value. Since 2.6.0.
-
fuzzingMode
public boolean fuzzingMode()
Deprecated.Use attribute 'ActorAttributes.FuzzingMode' to read the concrete setting value. Since 2.6.0.
-
autoFusing
public boolean autoFusing()
Deprecated.No longer has any effect. Since 2.6.0.
-
maxFixedBufferSize
public int maxFixedBufferSize()
Deprecated.Use attribute 'ActorAttributes.MaxFixedBufferSize' to read the concrete setting value. Since 2.6.0.
-
syncProcessingLimit
public int syncProcessingLimit()
Deprecated.Use attribute 'ActorAttributes.SyncProcessingLimit' to read the concrete setting value. Since 2.6.0.
-
ioSettings
public IOSettings ioSettings()
-
streamRefSettings
public StreamRefSettings streamRefSettings()
-
blockingIoDispatcher
public java.lang.String blockingIoDispatcher()
Deprecated.Use attribute 'ActorAttributes.BlockingIoDispatcher' to read the concrete setting value. Since 2.6.0.
-
withInputBuffer
public ActorMaterializerSettings withInputBuffer(int initialSize, int maxSize)
Deprecated.Use attribute 'Attributes.InputBuffer' to change setting value. Since 2.6.0.Each asynchronous piece of a materialized stream topology is executed by one Actor that manages an input buffer for all inlets of its shape. This setting configures the default for initial and maximal input buffer in number of elements for each inlet. This can be overridden for individual parts of the stream topology by usingAttributes.inputBuffer(int, int)
.FIXME: this is used for all kinds of buffers, not only the stream actor, some use initial some use max, document and or fix if it should not be like that. Search for get[Attributes.InputBuffer] to see how it is used
-
withDispatcher
public ActorMaterializerSettings withDispatcher(java.lang.String dispatcher)
Deprecated.Use attribute 'ActorAttributes.Dispatcher' to change setting value. Since 2.6.0.This setting configures the default dispatcher to be used by streams materialized with theActorMaterializer
. This can be overridden for individual parts of the stream topology by usingakka.stream.Attributes#dispatcher
.
-
withSupervisionStrategy
public ActorMaterializerSettings withSupervisionStrategy(scala.Function1<java.lang.Throwable,Supervision.Directive> decider)
Deprecated.Use attribute 'ActorAttributes.supervisionStrategy' to change setting value. Since 2.6.0.Scala API: Decides how exceptions from application code are to be handled, unless overridden for specific flows of the stream operations withakka.stream.Attributes#supervisionStrategy
.Note that supervision in streams are implemented on a per operator basis and is not supported by every operator.
-
withSupervisionStrategy
public ActorMaterializerSettings withSupervisionStrategy(Function<java.lang.Throwable,Supervision.Directive> decider)
Deprecated.Use attribute 'ActorAttributes.SupervisionStrategy' to change setting value. Since 2.6.0.Java API: Decides how exceptions from application code are to be handled, unless overridden for specific flows of the stream operations withakka.stream.Attributes#supervisionStrategy
.Note that supervision in streams are implemented on a per operator basis and is not supported by every operator.
-
withFuzzing
public ActorMaterializerSettings withFuzzing(boolean enable)
Deprecated.Use attribute 'ActorAttributes.FuzzingMode' to change setting value. Since 2.6.0.Test utility: fuzzing mode means that GraphStage events are not processed in FIFO order within a fused subgraph, but randomized.
-
withOutputBurstLimit
public ActorMaterializerSettings withOutputBurstLimit(int limit)
Deprecated.Use attribute 'ActorAttributes.OutputBurstLimit' to change setting value. Since 2.6.0.Maximum number of elements emitted in batch if downstream signals large demand.
-
withSyncProcessingLimit
public ActorMaterializerSettings withSyncProcessingLimit(int limit)
Deprecated.Use attribute 'ActorAttributes.SyncProcessingLimit' to change setting value. Since 2.6.0.Limit for number of messages that can be processed synchronously in stream to substream communication
-
withDebugLogging
public ActorMaterializerSettings withDebugLogging(boolean enable)
Deprecated.Use attribute 'ActorAttributes.DebugLogging' to change setting value. Since 2.6.0.Enable to log all elements that are dropped due to failures (at DEBUG level).
-
withMaxFixedBufferSize
public ActorMaterializerSettings withMaxFixedBufferSize(int size)
Deprecated.Use attribute 'ActorAttributes.MaxFixedBufferSize' to change setting value. Since 2.6.0.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.
-
withSubscriptionTimeoutSettings
public ActorMaterializerSettings withSubscriptionTimeoutSettings(StreamSubscriptionTimeoutSettings settings)
Leaked publishers and subscribers are cleaned up when they are not used within a given deadline, configured byStreamSubscriptionTimeoutSettings
.
-
withIOSettings
public ActorMaterializerSettings withIOSettings(IOSettings ioSettings)
-
withStreamRefSettings
public ActorMaterializerSettings withStreamRefSettings(StreamRefSettings streamRefSettings)
-
withBlockingIoDispatcher
public ActorMaterializerSettings withBlockingIoDispatcher(java.lang.String newBlockingIoDispatcher)
Deprecated.Use attribute 'ActorAttributes.BlockingIoDispatcher' to change setting value. Since 2.6.0.
-
equals
public boolean equals(java.lang.Object other)
- Overrides:
equals
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-