akka.stream

Class Attributes$

java.lang.Object

akka.stream.Attributes$

All Implemented Interfaces:

java.io.Serializable

public class Attributes$
extends java.lang.Object
implements scala.Serializable

Note that more attributes for the ActorMaterializer are defined in ActorAttributes.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static Attributes$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Attributes$()

Method Summary

Modifier and Type	Method and Description
Attributes	apply(Attributes.Attribute attribute) INTERNAL API
Attributes	asyncBoundary()
Attributes	createLogLevels(Logging.LogLevel onElement, Logging.LogLevel onFinish, Logging.LogLevel onFailure) Java API
java.lang.String	extractName(StreamLayout.Module mod, java.lang.String default_) Compute a name by concatenating all Name attributes that the given module has, returning the given default value if none are found.
Attributes	inputBuffer(int initial, int max) Specifies the initial and maximum size of the input buffer.
Attributes	logLevels(Logging.LogLevel onElement, Logging.LogLevel onFinish, Logging.LogLevel onFailure) Configures log() stage log-levels to be used when logging.
Attributes	name(java.lang.String name) Specifies the name of the operation.
Attributes	none() INTERNAL API

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final Attributes$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Attributes$

public Attributes$()

Method Detail

apply

public Attributes apply(Attributes.Attribute attribute)

INTERNAL API

Parameters:

attribute - (undocumented)

Returns:

(undocumented)

none

public Attributes none()

INTERNAL API

Returns:

(undocumented)

asyncBoundary

public Attributes asyncBoundary()

name

public Attributes name(java.lang.String name)

Specifies the name of the operation. If the name is null or empty the name is ignored, i.e. none() is returned.

Parameters:

name - (undocumented)

Returns:

(undocumented)

inputBuffer

public Attributes inputBuffer(int initial,
                              int max)

Specifies the initial and maximum size of the input buffer.

Parameters:

initial - (undocumented)

max - (undocumented)

Returns:

(undocumented)

createLogLevels

public 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 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)

extractName

public java.lang.String extractName(StreamLayout.Module mod,
                                    java.lang.String default_)

Compute a name by concatenating all Name attributes that the given module has, returning the given default value if none are found.

Parameters:

mod - (undocumented)

default_ - (undocumented)

Returns:

(undocumented)