diff --git a/akka-docs/src/main/paradox/distributed-data.md b/akka-docs/src/main/paradox/distributed-data.md index 4645097318..32a463fb96 100644 --- a/akka-docs/src/main/paradox/distributed-data.md +++ b/akka-docs/src/main/paradox/distributed-data.md @@ -774,11 +774,9 @@ data entries, because then the remote message size will be too large. ## Learn More about CRDTs - * [The Final Causal Frontier](http://www.ustream.tv/recorded/61448875) -talk by Sean Cribbs * [Eventually Consistent Data Structures](https://vimeo.com/43903960) talk by Sean Cribbs - * [Strong Eventual Consistency and Conflict-free Replicated Data Types](http://research.microsoft.com/apps/video/default.aspx?id=153540&r=1) + * [Strong Eventual Consistency and Conflict-free Replicated Data Types (video)](https://www.youtube.com/watch?v=oyUHd894w18&feature=youtu.be) talk by Mark Shapiro * [A comprehensive study of Convergent and Commutative Replicated Data Types](http://hal.upmc.fr/file/index/docid/555588/filename/techreport.pdf) paper by Mark Shapiro et. al. diff --git a/akka-stream/src/main/scala/akka/stream/Attributes.scala b/akka-stream/src/main/scala/akka/stream/Attributes.scala index af5ff3b53b..c2f05e6506 100644 --- a/akka-stream/src/main/scala/akka/stream/Attributes.scala +++ b/akka-stream/src/main/scala/akka/stream/Attributes.scala @@ -348,20 +348,25 @@ object Attributes { * Java API * * Configures `log()` operator log-levels to be used when logging. - * Logging a certain operation can be completely disabled by using [[LogLevels.Off]]. + * Logging a certain operation can be completely disabled by using [[Attributes#logLevelOff]]. * - * 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`. */ def createLogLevels(onElement: Logging.LogLevel, onFinish: Logging.LogLevel, onFailure: Logging.LogLevel): Attributes = - logLevels( - onElement = Option(onElement).getOrElse(Logging.DebugLevel), - onFinish = Option(onFinish).getOrElse(Logging.DebugLevel), - onFailure = Option(onFailure).getOrElse(Logging.ErrorLevel)) + logLevels(onElement, onFinish, onFailure) + + /** + * 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]]. + * + */ + def createLogLevels(onElement: Logging.LogLevel): Attributes = + logLevels(onElement) /** * Configures `log()` operator log-levels to be used when logging. - * Logging a certain operation can be completely disabled by using [[Attributes#logLevelOff]]. + * Logging a certain operation can be completely disabled by using [[LogLevels.Off]]. * * See [[Attributes.createLogLevels]] for Java API */ @@ -440,16 +445,21 @@ object ActorAttributes { * Java API * * Configures `log()` operator log-levels to be used when logging. - * Logging a certain operation can be completely disabled by using [[LogLevels.Off]]. + * Logging a certain operation can be completely disabled by using [[Attributes#logLevelOff]]. * - * 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`. */ def createLogLevels(onElement: Logging.LogLevel, onFinish: Logging.LogLevel, onFailure: Logging.LogLevel): Attributes = - logLevels( - onElement = Option(onElement).getOrElse(Logging.DebugLevel), - onFinish = Option(onFinish).getOrElse(Logging.DebugLevel), - onFailure = Option(onFailure).getOrElse(Logging.ErrorLevel)) + logLevels(onElement, onFinish, onFailure) + + /** + * 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]]. + * + */ + def createLogLevels(onElement: Logging.LogLevel): Attributes = + logLevels(onElement) /** * Configures `log()` operator log-levels to be used when logging.