diff --git a/akka-actor/src/main/scala/akka/serialization/Serialization.scala b/akka-actor/src/main/scala/akka/serialization/Serialization.scala index dab7700fe3..9c1ed14492 100644 --- a/akka-actor/src/main/scala/akka/serialization/Serialization.scala +++ b/akka-actor/src/main/scala/akka/serialization/Serialization.scala @@ -168,11 +168,8 @@ class Serialization(val system: ExtendedActorSystem) extends Extension { * serializerMap is a Map whose keys is the class that is serializable and values is the serializer * to be used for that class. */ - private val serializerMap: ConcurrentHashMap[Class[_], Serializer] = { - val serializerMap = new ConcurrentHashMap[Class[_], Serializer] - for ((c, s) ← bindings) serializerMap.put(c, s) - serializerMap - } + private val serializerMap: ConcurrentHashMap[Class[_], Serializer] = + (new ConcurrentHashMap[Class[_], Serializer] /: bindings) { case (map, (c, s)) ⇒ map.put(c, s); map } /** * Maps from a Serializer Identity (Int) to a Serializer instance (optimization) diff --git a/akka-remote-tests/src/main/scala/akka/remote/testconductor/Conductor.scala b/akka-remote-tests/src/main/scala/akka/remote/testconductor/Conductor.scala index b6265125b1..7f7f4225f0 100644 --- a/akka-remote-tests/src/main/scala/akka/remote/testconductor/Conductor.scala +++ b/akka-remote-tests/src/main/scala/akka/remote/testconductor/Conductor.scala @@ -3,6 +3,8 @@ */ package akka.remote.testconductor +import language.postfixOps + import akka.actor.{ Actor, ActorRef, ActorSystem, LoggingFSM, Props } import RemoteConnection.getAddrString import TestConductorProtocol._ @@ -430,6 +432,7 @@ private[akka] class Controller(private var initialParticipants: Int, controllerP case GetAddress(node) ⇒ if (nodes contains node) sender ! ToClient(AddressReply(node, nodes(node).addr)) else addrInterest += node -> ((addrInterest get node getOrElse Set()) + sender) + case _: Done ⇒ //FIXME what should happen? } case op: CommandOp ⇒ op match { diff --git a/akka-remote-tests/src/main/scala/akka/remote/testconductor/DataTypes.scala b/akka-remote-tests/src/main/scala/akka/remote/testconductor/DataTypes.scala index 830b32e485..4924e6c420 100644 --- a/akka-remote-tests/src/main/scala/akka/remote/testconductor/DataTypes.scala +++ b/akka-remote-tests/src/main/scala/akka/remote/testconductor/DataTypes.scala @@ -3,6 +3,8 @@ */ package akka.remote.testconductor +import language.implicitConversions + import org.jboss.netty.handler.codec.oneone.OneToOneEncoder import org.jboss.netty.channel.ChannelHandlerContext import org.jboss.netty.channel.Channel diff --git a/akka-remote-tests/src/main/scala/akka/remote/testconductor/NetworkFailureInjector.scala b/akka-remote-tests/src/main/scala/akka/remote/testconductor/NetworkFailureInjector.scala index 2d5b73216e..b41d93ad66 100644 --- a/akka-remote-tests/src/main/scala/akka/remote/testconductor/NetworkFailureInjector.scala +++ b/akka-remote-tests/src/main/scala/akka/remote/testconductor/NetworkFailureInjector.scala @@ -3,6 +3,8 @@ */ package akka.remote.testconductor +import language.postfixOps + import java.net.InetSocketAddress import scala.annotation.tailrec diff --git a/akka-remote-tests/src/main/scala/akka/remote/testconductor/Player.scala b/akka-remote-tests/src/main/scala/akka/remote/testconductor/Player.scala index c7f69091cf..57869dca81 100644 --- a/akka-remote-tests/src/main/scala/akka/remote/testconductor/Player.scala +++ b/akka-remote-tests/src/main/scala/akka/remote/testconductor/Player.scala @@ -3,6 +3,8 @@ */ package akka.remote.testconductor +import language.postfixOps + import akka.actor.{ Actor, ActorRef, ActorSystem, LoggingFSM, Props } import RemoteConnection.getAddrString import akka.util.duration._ @@ -184,7 +186,7 @@ private[akka] class ClientFSM(name: RoleName, controllerAddr: InetSocketAddress) case Event(Disconnected, _) ⇒ log.info("disconnected from TestConductor") throw new ConnectionFailure("disconnect") - case Event(ToServer(Done), Data(Some(channel), _)) ⇒ + case Event(ToServer(_: Done), Data(Some(channel), _)) ⇒ channel.write(Done) stay case Event(ToServer(msg), d @ Data(Some(channel), None)) ⇒ @@ -232,6 +234,7 @@ private[akka] class ClientFSM(name: RoleName, controllerAddr: InetSocketAddress) case TerminateMsg(exit) ⇒ System.exit(exit) stay // needed because Java doesn’t have Nothing + case _: Done ⇒ stay //FIXME what should happen? } } diff --git a/akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala b/akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala index f418f4a717..6cc8cfdf52 100644 --- a/akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala +++ b/akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala @@ -3,6 +3,8 @@ */ package akka.remote.testconductor +import language.postfixOps + import akka.testkit.AkkaSpec import akka.actor.Props import akka.actor.AddressFromURIString diff --git a/akka-remote-tests/src/test/scala/akka/remote/testkit/MultiNodeSpec.scala b/akka-remote-tests/src/test/scala/akka/remote/testkit/MultiNodeSpec.scala index 4d65a2084e..ad036192c2 100644 --- a/akka-remote-tests/src/test/scala/akka/remote/testkit/MultiNodeSpec.scala +++ b/akka-remote-tests/src/test/scala/akka/remote/testkit/MultiNodeSpec.scala @@ -3,6 +3,8 @@ */ package akka.remote.testkit +import language.implicitConversions + import java.net.InetSocketAddress import com.typesafe.config.{ ConfigObject, ConfigFactory, Config }