diff --git a/akka-actor/src/main/scala/akka/event/Logging.scala b/akka-actor/src/main/scala/akka/event/Logging.scala
index face9a20d9..eab5ca716b 100644
--- a/akka-actor/src/main/scala/akka/event/Logging.scala
+++ b/akka-actor/src/main/scala/akka/event/Logging.scala
@@ -16,6 +16,7 @@ import akka.actor.ActorRefProvider
 import scala.util.control.NoStackTrace
 import java.util.concurrent.TimeoutException
 import akka.dispatch.Await
+import annotation.switch
 
 object LoggingBus {
   implicit def fromActorSystem(system: ActorSystem): LoggingBus = system.eventStream
@@ -516,34 +517,54 @@ trait LoggingAdapter {
    */
 
   def error(cause: Throwable, message: String) { if (isErrorEnabled) notifyError(cause, message) }
-  def error(cause: Throwable, template: String, arg1: Any) { if (isErrorEnabled) error(cause, format(template, arg1)) }
-  def error(cause: Throwable, template: String, arg1: Any, arg2: Any) { if (isErrorEnabled) error(cause, format(template, arg1, arg2)) }
-  def error(cause: Throwable, template: String, arg1: Any, arg2: Any, arg3: Any) { if (isErrorEnabled) error(cause, format(template, arg1, arg2, arg3)) }
-  def error(cause: Throwable, template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isErrorEnabled) error(cause, format(template, arg1, arg2, arg3, arg4)) }
+  def error(cause: Throwable, template: String, arg1: Any) { if (isErrorEnabled) notifyError(cause, format(template, arg1)) }
+  def error(cause: Throwable, template: String, arg1: Any, arg2: Any) { if (isErrorEnabled) notifyError(cause, format(template, arg1, arg2)) }
+  def error(cause: Throwable, template: String, arg1: Any, arg2: Any, arg3: Any) { if (isErrorEnabled) notifyError(cause, format(template, arg1, arg2, arg3)) }
+  def error(cause: Throwable, template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isErrorEnabled) notifyError(cause, format(template, arg1, arg2, arg3, arg4)) }
 
   def error(message: String) { if (isErrorEnabled) notifyError(message) }
-  def error(template: String, arg1: Any) { if (isErrorEnabled) error(format(template, arg1)) }
-  def error(template: String, arg1: Any, arg2: Any) { if (isErrorEnabled) error(format(template, arg1, arg2)) }
-  def error(template: String, arg1: Any, arg2: Any, arg3: Any) { if (isErrorEnabled) error(format(template, arg1, arg2, arg3)) }
-  def error(template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isErrorEnabled) error(format(template, arg1, arg2, arg3, arg4)) }
+  def error(template: String, arg1: Any) { if (isErrorEnabled) notifyError(format(template, arg1)) }
+  def error(template: String, arg1: Any, arg2: Any) { if (isErrorEnabled) notifyError(format(template, arg1, arg2)) }
+  def error(template: String, arg1: Any, arg2: Any, arg3: Any) { if (isErrorEnabled) notifyError(format(template, arg1, arg2, arg3)) }
+  def error(template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isErrorEnabled) notifyError(format(template, arg1, arg2, arg3, arg4)) }
 
   def warning(message: String) { if (isWarningEnabled) notifyWarning(message) }
-  def warning(template: String, arg1: Any) { if (isWarningEnabled) warning(format(template, arg1)) }
-  def warning(template: String, arg1: Any, arg2: Any) { if (isWarningEnabled) warning(format(template, arg1, arg2)) }
-  def warning(template: String, arg1: Any, arg2: Any, arg3: Any) { if (isWarningEnabled) warning(format(template, arg1, arg2, arg3)) }
-  def warning(template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isWarningEnabled) warning(format(template, arg1, arg2, arg3, arg4)) }
+  def warning(template: String, arg1: Any) { if (isWarningEnabled) notifyWarning(format(template, arg1)) }
+  def warning(template: String, arg1: Any, arg2: Any) { if (isWarningEnabled) notifyWarning(format(template, arg1, arg2)) }
+  def warning(template: String, arg1: Any, arg2: Any, arg3: Any) { if (isWarningEnabled) notifyWarning(format(template, arg1, arg2, arg3)) }
+  def warning(template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isWarningEnabled) notifyWarning(format(template, arg1, arg2, arg3, arg4)) }
 
   def info(message: String) { if (isInfoEnabled) notifyInfo(message) }
-  def info(template: String, arg1: Any) { if (isInfoEnabled) info(format(template, arg1)) }
-  def info(template: String, arg1: Any, arg2: Any) { if (isInfoEnabled) info(format(template, arg1, arg2)) }
-  def info(template: String, arg1: Any, arg2: Any, arg3: Any) { if (isInfoEnabled) info(format(template, arg1, arg2, arg3)) }
-  def info(template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isInfoEnabled) info(format(template, arg1, arg2, arg3, arg4)) }
+  def info(template: String, arg1: Any) { if (isInfoEnabled) notifyInfo(format(template, arg1)) }
+  def info(template: String, arg1: Any, arg2: Any) { if (isInfoEnabled) notifyInfo(format(template, arg1, arg2)) }
+  def info(template: String, arg1: Any, arg2: Any, arg3: Any) { if (isInfoEnabled) notifyInfo(format(template, arg1, arg2, arg3)) }
+  def info(template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isInfoEnabled) notifyInfo(format(template, arg1, arg2, arg3, arg4)) }
 
   def debug(message: String) { if (isDebugEnabled) notifyDebug(message) }
-  def debug(template: String, arg1: Any) { if (isDebugEnabled) debug(format(template, arg1)) }
-  def debug(template: String, arg1: Any, arg2: Any) { if (isDebugEnabled) debug(format(template, arg1, arg2)) }
-  def debug(template: String, arg1: Any, arg2: Any, arg3: Any) { if (isDebugEnabled) debug(format(template, arg1, arg2, arg3)) }
-  def debug(template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isDebugEnabled) debug(format(template, arg1, arg2, arg3, arg4)) }
+  def debug(template: String, arg1: Any) { if (isDebugEnabled) notifyDebug(format(template, arg1)) }
+  def debug(template: String, arg1: Any, arg2: Any) { if (isDebugEnabled) notifyDebug(format(template, arg1, arg2)) }
+  def debug(template: String, arg1: Any, arg2: Any, arg3: Any) { if (isDebugEnabled) notifyDebug(format(template, arg1, arg2, arg3)) }
+  def debug(template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isDebugEnabled) notifyDebug(format(template, arg1, arg2, arg3, arg4)) }
+
+  def log(level: Logging.LogLevel, message: String) { if (isEnabled(level)) notifyLog(level, message) }
+  def log(level: Logging.LogLevel, template: String, arg1: Any) { if (isEnabled(level)) notifyLog(level, format(template, arg1)) }
+  def log(level: Logging.LogLevel, template: String, arg1: Any, arg2: Any) { if (isEnabled(level)) notifyLog(level, format(template, arg1, arg2)) }
+  def log(level: Logging.LogLevel, template: String, arg1: Any, arg2: Any, arg3: Any) { if (isEnabled(level)) notifyLog(level, format(template, arg1, arg2, arg3)) }
+  def log(level: Logging.LogLevel, template: String, arg1: Any, arg2: Any, arg3: Any, arg4: Any) { if (isEnabled(level)) notifyLog(level, format(template, arg1, arg2, arg3, arg4)) }
+
+  final def isEnabled(level: Logging.LogLevel): Boolean = level match {
+    case Logging.ErrorLevel   ⇒ isErrorEnabled
+    case Logging.WarningLevel ⇒ isWarningEnabled
+    case Logging.InfoLevel    ⇒ isInfoEnabled
+    case Logging.DebugLevel   ⇒ isDebugEnabled
+  }
+
+  final def notifyLog(level: Logging.LogLevel, message: String): Unit = level match {
+    case Logging.ErrorLevel   ⇒ if (isErrorEnabled) notifyError(message)
+    case Logging.WarningLevel ⇒ if (isWarningEnabled) notifyWarning(message)
+    case Logging.InfoLevel    ⇒ if (isInfoEnabled) notifyInfo(message)
+    case Logging.DebugLevel   ⇒ if (isDebugEnabled) notifyDebug(message)
+  }
 
   def format(t: String, arg: Any*) = {
     val sb = new StringBuilder
diff --git a/akka-remote/src/main/scala/akka/remote/RemoteInterface.scala b/akka-remote/src/main/scala/akka/remote/RemoteInterface.scala
index 4e6730f65b..ff01e8eb26 100644
--- a/akka-remote/src/main/scala/akka/remote/RemoteInterface.scala
+++ b/akka-remote/src/main/scala/akka/remote/RemoteInterface.scala
@@ -14,6 +14,7 @@ import java.net.URISyntaxException
 import java.net.InetAddress
 import java.net.UnknownHostException
 import java.net.UnknownServiceException
+import akka.event.Logging
 
 /**
  * Interface for remote transports to encode their addresses. The three parts
@@ -135,7 +136,9 @@ trait RemoteModule {
 /**
  * Remote life-cycle events.
  */
-sealed trait RemoteLifeCycleEvent
+sealed trait RemoteLifeCycleEvent {
+  def logLevel: Logging.LogLevel
+}
 
 /**
  * Life-cycle events for RemoteClient.
@@ -148,6 +151,7 @@ case class RemoteClientError[T <: ParsedTransportAddress](
   @BeanProperty cause: Throwable,
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty remoteAddress: T) extends RemoteClientLifeCycleEvent {
+  override def logLevel = Logging.ErrorLevel
   override def toString =
     "RemoteClientError@" +
       remoteAddress +
@@ -159,6 +163,7 @@ case class RemoteClientError[T <: ParsedTransportAddress](
 case class RemoteClientDisconnected[T <: ParsedTransportAddress](
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty remoteAddress: T) extends RemoteClientLifeCycleEvent {
+  override def logLevel = Logging.DebugLevel
   override def toString =
     "RemoteClientDisconnected@" + remoteAddress
 }
@@ -166,6 +171,7 @@ case class RemoteClientDisconnected[T <: ParsedTransportAddress](
 case class RemoteClientConnected[T <: ParsedTransportAddress](
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty remoteAddress: T) extends RemoteClientLifeCycleEvent {
+  override def logLevel = Logging.DebugLevel
   override def toString =
     "RemoteClientConnected@" + remoteAddress
 }
@@ -173,6 +179,7 @@ case class RemoteClientConnected[T <: ParsedTransportAddress](
 case class RemoteClientStarted[T <: ParsedTransportAddress](
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty remoteAddress: T) extends RemoteClientLifeCycleEvent {
+  override def logLevel = Logging.InfoLevel
   override def toString =
     "RemoteClientStarted@" + remoteAddress
 }
@@ -180,6 +187,7 @@ case class RemoteClientStarted[T <: ParsedTransportAddress](
 case class RemoteClientShutdown[T <: ParsedTransportAddress](
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty remoteAddress: T) extends RemoteClientLifeCycleEvent {
+  override def logLevel = Logging.InfoLevel
   override def toString =
     "RemoteClientShutdown@" + remoteAddress
 }
@@ -189,6 +197,7 @@ case class RemoteClientWriteFailed[T <: ParsedTransportAddress](
   @BeanProperty cause: Throwable,
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty remoteAddress: T) extends RemoteClientLifeCycleEvent {
+  override def logLevel = Logging.WarningLevel
   override def toString =
     "RemoteClientWriteFailed@" +
       remoteAddress +
@@ -206,12 +215,14 @@ trait RemoteServerLifeCycleEvent extends RemoteLifeCycleEvent
 
 case class RemoteServerStarted[T <: ParsedTransportAddress](
   @BeanProperty remote: RemoteSupport[T]) extends RemoteServerLifeCycleEvent {
+  override def logLevel = Logging.InfoLevel
   override def toString =
     "RemoteServerStarted@" + remote.name
 }
 
 case class RemoteServerShutdown[T <: ParsedTransportAddress](
   @BeanProperty remote: RemoteSupport[T]) extends RemoteServerLifeCycleEvent {
+  override def logLevel = Logging.InfoLevel
   override def toString =
     "RemoteServerShutdown@" + remote.name
 }
@@ -219,6 +230,7 @@ case class RemoteServerShutdown[T <: ParsedTransportAddress](
 case class RemoteServerError[T <: ParsedTransportAddress](
   @BeanProperty val cause: Throwable,
   @BeanProperty remote: RemoteSupport[T]) extends RemoteServerLifeCycleEvent {
+  override def logLevel = Logging.ErrorLevel
   override def toString =
     "RemoteServerError@" +
       remote.name +
@@ -230,6 +242,7 @@ case class RemoteServerError[T <: ParsedTransportAddress](
 case class RemoteServerClientConnected[T <: ParsedTransportAddress](
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty val clientAddress: Option[T]) extends RemoteServerLifeCycleEvent {
+  override def logLevel = Logging.DebugLevel
   override def toString =
     "RemoteServerClientConnected@" +
       remote.name +
@@ -241,6 +254,7 @@ case class RemoteServerClientConnected[T <: ParsedTransportAddress](
 case class RemoteServerClientDisconnected[T <: ParsedTransportAddress](
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty val clientAddress: Option[T]) extends RemoteServerLifeCycleEvent {
+  override def logLevel = Logging.DebugLevel
   override def toString =
     "RemoteServerClientDisconnected@" +
       remote.name +
@@ -252,6 +266,7 @@ case class RemoteServerClientDisconnected[T <: ParsedTransportAddress](
 case class RemoteServerClientClosed[T <: ParsedTransportAddress](
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty val clientAddress: Option[T]) extends RemoteServerLifeCycleEvent {
+  override def logLevel = Logging.DebugLevel
   override def toString =
     "RemoteServerClientClosed@" +
       remote.name +
@@ -265,6 +280,7 @@ case class RemoteServerWriteFailed[T <: ParsedTransportAddress](
   @BeanProperty cause: Throwable,
   @BeanProperty remote: RemoteSupport[T],
   @BeanProperty remoteAddress: Option[T]) extends RemoteServerLifeCycleEvent {
+  override def logLevel = Logging.WarningLevel
   override def toString =
     "RemoteServerWriteFailed@" +
       remote +
@@ -320,7 +336,7 @@ abstract class RemoteSupport[-T <: ParsedTransportAddress](val system: ActorSyst
 
   protected[akka] def notifyListeners(message: RemoteLifeCycleEvent): Unit = {
     system.eventStream.publish(message)
-    system.log.debug("REMOTE: {}", message)
+    system.log.log(message.logLevel, "REMOTE: {}", message)
   }
 
   override def toString = name