raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge pull request #1947 from akka/wip-ReliableProxy-javadoc-patriknw

Browse source 
=con Unbork genjavadoc for ReliableProxy
This commit is contained in:
Patrik Nordwall 2014-01-20 09:57:19 -08:00
commit 1c0e799370
1 changed files with 16 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

28
akka-contrib/src/main/scala/akka/contrib/pattern/ReliableProxy.scala
View file

@ -44,7 +44,7 @@ object ReliableProxy {
props(targetPath, retryAfter, None, None)
}
class Receiver(target: ActorRef, initialSerial: Int) extends Actor with DebugLogging {
class Receiver(target: ActorRef, initialSerial: Int) extends Actor with ReliableProxyDebugLogging {
var lastSerial = initialSerial
context.watch(target)
@ -108,20 +108,24 @@ object ReliableProxy {
val active = Active
val reconnecting = Connecting
trait DebugLogging extends ActorLogging { this: Actor ⇒
val debug =
Try(context.system.settings.config.getBoolean("akka.reliable-proxy.debug")) getOrElse false
}
def enabled = debug && log.isDebugEnabled
/**
* INTERNAL API
*/
private[akka] trait ReliableProxyDebugLogging extends ActorLogging { this: Actor ⇒
val debug: Boolean =
Try(context.system.settings.config.getBoolean("akka.reliable-proxy.debug")) getOrElse false
def addSelf(template: String) = s"$template [$self]"
def enabled: Boolean = debug && log.isDebugEnabled
def logDebug(template: String, arg1: Any, arg2: Any): Unit =
if (enabled) log.debug(addSelf(template), arg1, arg2)
def addSelf(template: String): String = s"$template [$self]"
def logDebug(template: String, arg1: Any): Unit =
if (enabled) log.debug(addSelf(template), arg1)
}
def logDebug(template: String, arg1: Any, arg2: Any): Unit =
if (enabled) log.debug(addSelf(template), arg1, arg2)
def logDebug(template: String, arg1: Any): Unit =
if (enabled) log.debug(addSelf(template), arg1)
}
import ReliableProxy._
@ -220,7 +224,7 @@ import ReliableProxy._
*/
class ReliableProxy(targetPath: ActorPath, retryAfter: FiniteDuration,
reconnectAfter: Option[FiniteDuration], maxConnectAttempts: Option[Int])
extends Actor with LoggingFSM[State, Vector[Message]] with DebugLogging {
extends Actor with LoggingFSM[State, Vector[Message]] with ReliableProxyDebugLogging {
var tunnel: ActorRef = _
var currentSerial: Int = 0