removed trailing whitespace

akka-actor/src/main/scala/akka/dispatch/ExecutorBasedEventDrivenDispatcher.scala

@@ -120,7 +120,7 @@ class ExecutorBasedEventDrivenDispatcher(
   /**
    * Creates and returns a durable mailbox for the given actor.
    */
-  private[akka] def createDurableMailbox(actorRef: ActorRef, mailboxType: DurableMailboxType): AnyRef = 
+  private[akka] def createDurableMailbox(actorRef: ActorRef, mailboxType: DurableMailboxType): AnyRef =
     createMailbox(mailboxType.mailboxImplClassname, actorRef)
 
   private[akka] def start = log.slf4j.debug("Starting up {}\n\twith throughput [{}]", this, throughput)

akka-actor/src/main/scala/akka/dispatch/ExecutorBasedEventDrivenWorkStealingDispatcher.scala

@@ -224,7 +224,7 @@ class ExecutorBasedEventDrivenWorkStealingDispatcher(
   /**
    * Creates and returns a durable mailbox for the given actor.
    */
-  private[akka] def createDurableMailbox(actorRef: ActorRef, mailboxType: DurableMailboxType): AnyRef = 
+  private[akka] def createDurableMailbox(actorRef: ActorRef, mailboxType: DurableMailboxType): AnyRef =
     createMailbox(mailboxType.mailboxImplClassname, actorRef)
 
   private[akka] override def register(actorRef: ActorRef) = {

akka-http/src/main/scala/JettyContinuation.scala

@@ -84,7 +84,7 @@ trait JettyContinuation extends ContinuationListener with akka.util.Logging
     case None => false
     case Some(continuation) => (continuation.isSuspended || (continuation.getAttribute(TimeoutAttribute) ne null))
   }
-  
+
   def timeout(ms:Long):Boolean = _continuation match {
     case None => false
     case Some(continuation) =>

akka-remote/src/main/scala/akka/remote/BootableRemoteActorService.scala

@@ -22,7 +22,7 @@ trait BootableRemoteActorService extends Bootable with Logging {
       else RemoteNode.start
     }
   }, "Akka Remote Service")
- 
+
   def startRemoteService = remoteServerThread.start
 
   abstract override def onLoad = {

akka-remote/src/main/scala/akka/remote/RemoteClient.scala

@@ -290,15 +290,15 @@ class RemoteClient private[akka] (
     else None
     send(createRemoteMessageProtocolBuilder(
         Some(actorRef),
-        Left(actorRef.uuid), 
+        Left(actorRef.uuid),
-        actorRef.id, 
+        actorRef.id,
-        actorRef.actorClassName, 
+        actorRef.actorClassName,
-        actorRef.timeout, 
+        actorRef.timeout,
-        Left(message), 
+        Left(message),
-        isOneWay, 
+        isOneWay,
-        senderOption, 
+        senderOption,
-        typedActorInfo, 
+        typedActorInfo,
-        actorType, 
+        actorType,
         cookie
       ).build, senderFuture)
   }

akka-remote/src/main/scala/akka/remote/RemoteServer.scala

@@ -161,16 +161,16 @@ case class RemoteServerStarted(
 case class RemoteServerShutdown(
   @BeanProperty val server: RemoteServer) extends RemoteServerLifeCycleEvent
 case class RemoteServerError(
-  @BeanProperty val cause: Throwable, 
+  @BeanProperty val cause: Throwable,
   @BeanProperty val server: RemoteServer) extends RemoteServerLifeCycleEvent
 case class RemoteServerClientConnected(
-  @BeanProperty val server: RemoteServer, 
+  @BeanProperty val server: RemoteServer,
   @BeanProperty val clientAddress: Option[InetSocketAddress]) extends RemoteServerLifeCycleEvent
 case class RemoteServerClientDisconnected(
-  @BeanProperty val server: RemoteServer, 
+  @BeanProperty val server: RemoteServer,
   @BeanProperty val clientAddress: Option[InetSocketAddress]) extends RemoteServerLifeCycleEvent
 case class RemoteServerClientClosed(
-  @BeanProperty val server: RemoteServer, 
+  @BeanProperty val server: RemoteServer,
   @BeanProperty val clientAddress: Option[InetSocketAddress]) extends RemoteServerLifeCycleEvent
 
 /**
@@ -726,7 +726,7 @@ class RemoteServerHandler(
   }
 
   private def findActorFactory(id: String) : () => ActorRef = {
-    server.actorsFactories.get(id) 
+    server.actorsFactories.get(id)
   }
 
   private def findSessionActor(id: String, channel: Channel) : ActorRef = {
@@ -840,7 +840,7 @@ class RemoteServerHandler(
     {
       // the actor has not been registered globally. See if we have it in the session
       val sessionActorRefOrNull = createSessionActor(actorInfo, channel)
-      if (sessionActorRefOrNull ne null) 
+      if (sessionActorRefOrNull ne null)
         sessionActorRefOrNull
       else  // maybe it is a client managed actor
         createClientManagedActor(actorInfo)
@@ -863,7 +863,7 @@ class RemoteServerHandler(
         newInstance
       }
       else
-        null       
+        null
     }
 
   }
@@ -921,15 +921,15 @@ class RemoteServerHandler(
     log.slf4j.debug("Could not invoke remote actor", exception)
     val messageBuilder = RemoteActorSerialization.createRemoteMessageProtocolBuilder(
       None,
-      Right(request.getUuid), 
+      Right(request.getUuid),
-      actorInfo.getId, 
+      actorInfo.getId,
-      actorInfo.getTarget, 
+      actorInfo.getTarget,
-      actorInfo.getTimeout, 
+      actorInfo.getTimeout,
-      Right(exception), 
+      Right(exception),
-      true, 
+      true,
-      None, 
+      None,
-      None, 
+      None,
-      actorType, 
+      actorType,
       None)
     if (request.hasSupervisorUuid) messageBuilder.setSupervisorUuid(request.getSupervisorUuid)
     messageBuilder.build

akka-remote/src/main/scala/akka/serialization/SerializationProtocol.scala

@@ -299,9 +299,9 @@ object RemoteActorSerialization {
         .setOneWay(isOneWay)
 
     message match {
-      case Left(message) => 
+      case Left(message) =>
         messageBuilder.setMessage(MessageSerializer.serialize(message))
-      case Right(exception) => 
+      case Right(exception) =>
         messageBuilder.setException(ExceptionProtocol.newBuilder
             .setClassname(exception.getClass.getName)
             .setMessage(exception.getMessage)
@@ -310,7 +310,7 @@ object RemoteActorSerialization {
 
     secureCookie.foreach(messageBuilder.setCookie(_))
 
-    actorRef.foreach { ref => 
+    actorRef.foreach { ref =>
       ref.registerSupervisorAsRemoteActor.foreach { id =>
         messageBuilder.setSupervisorUuid(
           UuidProtocol.newBuilder

akka-remote/src/test/scala/remote/ServerInitiatedRemoteActorSpec.scala

@@ -4,7 +4,7 @@ import java.util.concurrent.{CountDownLatch, TimeUnit}
 import org.scalatest.junit.JUnitSuite
 import org.junit.{Test, Before, After}
 import akka.util._
-                                       
+
 import akka.remote.{RemoteServer, RemoteClient}
 import akka.actor.Actor._
 import akka.actor.{ActorRegistry, ActorRef, Actor}

akka-remote/src/test/scala/remote/ServerInitiatedRemoteTypedSessionActorSpec.scala

@@ -98,7 +98,7 @@ class ServerInitiatedRemoteTypedSessionActorSpec extends
 
   it should "be able to unregister" in {
     server.registerTypedPerSessionActor("my-service-1",TypedActor.newInstance(classOf[RemoteTypedSessionActor], classOf[RemoteTypedSessionActorImpl], 1000))
-    
+
     server.typedActorsFactories.get("my-service-1") should not be (null)
     server.unregisterTypedPerSessionActor("my-service-1")
     server.typedActorsFactories.get("my-service-1") should be (null)

project/build/AkkaProject.scala

@@ -111,7 +111,7 @@ class AkkaParentProject(info: ProjectInfo) extends DefaultProject(info) {
   lazy val SLF4J_VERSION         = "1.6.0"
   lazy val JETTY_VERSION         = "7.1.6.v20100715"
   lazy val JAVAX_SERVLET_VERSION = "3.0"
-  
+
 
   // -------------------------------------------------------------------------------------------------------------------
   // Dependencies
@@ -138,7 +138,7 @@ class AkkaParentProject(info: ProjectInfo) extends DefaultProject(info) {
     lazy val dispatch_json = "net.databinder" % "dispatch-json_2.8.0" % DISPATCH_VERSION % "compile" //LGPL v2
 
     lazy val javax_servlet_30 = "org.glassfish" % "javax.servlet" % JAVAX_SERVLET_VERSION % "provided" //CDDL v1
-   
+
     lazy val jetty         = "org.eclipse.jetty" % "jetty-server"  % JETTY_VERSION % "compile" //Eclipse license
     lazy val jetty_util    = "org.eclipse.jetty" % "jetty-util"    % JETTY_VERSION % "compile" //Eclipse license
     lazy val jetty_xml     = "org.eclipse.jetty" % "jetty-xml"     % JETTY_VERSION % "compile" //Eclipse license
@@ -154,7 +154,7 @@ class AkkaParentProject(info: ProjectInfo) extends DefaultProject(info) {
 
     lazy val jackson          = "org.codehaus.jackson" % "jackson-mapper-asl" % JACKSON_VERSION % "compile" //ApacheV2
     lazy val jackson_core     = "org.codehaus.jackson" % "jackson-core-asl"   % JACKSON_VERSION % "compile" //ApacheV2
-    
+
     lazy val jersey         = "com.sun.jersey"          % "jersey-core"   % JERSEY_VERSION % "compile" //CDDL v1
     lazy val jersey_json    = "com.sun.jersey"          % "jersey-json"   % JERSEY_VERSION % "compile" //CDDL v1
     lazy val jersey_server  = "com.sun.jersey"          % "jersey-server" % JERSEY_VERSION % "compile" //CDDL v1