Package akka.stream

Class ActorAttributes

java.lang.Object

akka.stream.ActorAttributes

public class ActorAttributes
extends java.lang.Object

INTERNAL API Resolves the dispatcher's name with a fallback to the default blocking IO dispatcher. Note that IODispatcher.dispatcher is not used here as the config used to create ActorMaterializerSettings is not easily accessible, instead the name is taken from settings.blockingIoDispatcher

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ActorAttributes.Dispatcher
static class	ActorAttributes.Dispatcher$
static class	ActorAttributes.SupervisionStrategy
static class	ActorAttributes.SupervisionStrategy$

Constructor Summary

Constructors

Constructor	Description
ActorAttributes()

Method Summary

Modifier and Type	Method	Description
static Attributes	createLogLevels(Logging.LogLevel onElement)	Java API
static Attributes	createLogLevels(Logging.LogLevel onElement, Logging.LogLevel onFinish, Logging.LogLevel onFailure)	Java API
static Attributes	dispatcher(java.lang.String dispatcher)	Specifies the name of the dispatcher.
static ActorAttributes.Dispatcher	IODispatcher()
static Attributes	logLevels(Logging.LogLevel onElement, Logging.LogLevel onFinish, Logging.LogLevel onFailure)	Configures log() operator log-levels to be used when logging.
static Logging.LogLevel	logLevels$default$1()
static Logging.LogLevel	logLevels$default$2()
static Logging.LogLevel	logLevels$default$3()
static Attributes	supervisionStrategy(scala.Function1<java.lang.Throwable,Supervision.Directive> decider)	Scala API: Decides how exceptions from user are to be handled.
static Attributes	withSupervisionStrategy(Function<java.lang.Throwable,Supervision.Directive> decider)	Java API: Decides how exceptions from application code are to be handled.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ActorAttributes

public ActorAttributes()

Method Detail

IODispatcher

public static ActorAttributes.Dispatcher IODispatcher()

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)

logLevels$default$1

public static Logging.LogLevel logLevels$default$1()

logLevels$default$2

public static Logging.LogLevel logLevels$default$2()

logLevels$default$3

public static Logging.LogLevel logLevels$default$3()