Potential fix for #723

2011-03-27 00:01:18 +01:00 · 2011-03-27 00:01:18 +01:00 · f853c05031
commit f853c05031
parent 65a69537b7
1 changed files with 1 additions and 0 deletions
--- a/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala
+++ b/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala
@ -82,6 +82,7 @@ trait NettyRemoteClientModule extends RemoteClientModule { self: ListenerManagem

  private[akka] def withClientFor[T](
    address: InetSocketAddress, loader: Option[ClassLoader])(fun: RemoteClient => T): T = {
+    loader.foreach(MessageSerializer.setClassLoader(_))
    val key = Address(address)
    lock.readLock.lock
    try {