akka.stream

Class ActorAttributes

java.lang.Object

akka.stream.ActorAttributes

public class ActorAttributes
extends java.lang.Object

Attributes for the ActorMaterializer. Note that more attributes defined in Attributes.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
ActorAttributes()

Method Summary

Modifier and Type	Method and Description
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() stage log-levels to be used when logging.
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.

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.

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.

Parameters:

decider - (undocumented)

Returns:

(undocumented)

createLogLevels

public static Attributes createLogLevels(Logging.LogLevel onElement,
                                         Logging.LogLevel onFinish,
                                         Logging.LogLevel onFailure)

Java API

Configures log() stage log-levels to be used when logging. Logging a certain operation can be completely disabled by using LogLevels.Off.

Passing in null as any of the arguments sets the level to its default value, which is: Debug for onElement and onFinish, and Error for onFailure.

Parameters:

onElement - (undocumented)

onFinish - (undocumented)

onFailure - (undocumented)

Returns:

(undocumented)

logLevels

public static Attributes logLevels(Logging.LogLevel onElement,
                                   Logging.LogLevel onFinish,
                                   Logging.LogLevel onFailure)

Configures log() stage 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)