抽象的なリモートアクターとパターンマッチング（クラスローディング？）をスカラで拡張する

Question

Actorを拡張し、いくつかの追加機能[1]を提供するいくつかの抽象クラスを実装しています。しかし、パターンマッチングは受信ステートメント内では機能していないようです。私は、クライアントからサーバにケースオブジェクトConnectを送信し、フォームのサーバーでパターンマッチを持っている場合：

println("Starting to receive, e.g. " + Connect.getClass.toString) 
receive { 
    case Connect => println("Got a connected message") 
    case m => println("Got something weird: " + m + " of type " + m.getClass.toString) 
} 

次に出力は、着信メッセージが認識されない

Starting to receive, e.g. class ConnectionTest$Connect$ 
Got something weird: Connect of type class ConnectionTest$Connect$ 
... 

ですgetClassがそうだとしても、パターン一致のConnectオブジェクトと同じです。さらに奇妙な点：mはConnectと同じhashCodeを持ち、ObjectOutputStreamとwriteObjectを使ってまったく同じByteArrayにシリアル化されますが、それと等しくありません（==を使用）。私の最高の推測では、classLoaderは何らかの形で誤って動作していますが、私は迷っています。ここで

は私が書くしようとしているかのより完全な例です：

import scala.actors.{Actor, OutputChannel} 
import scala.actors.Actor._ 
import scala.actors.remote.RemoteActor 
import scala.actors.remote.RemoteActor._ 
import scala.actors.remote.Node 

abstract class ConnectionTest(masterNode: Node, port: Int) { 

    trait Message 
    case object Connect extends Message 

    abstract class Master extends Actor { 
    def act { 
     RemoteActor.classLoader = getClass.getClassLoader 
     alive(port) 
     register('MasterProcess, self) 

     while (true) { 
     println("Starting to receive, e.g. " + Connect.getClass.toString) 
     receive { 
      case Connect => println("Got a connect message") 
      case m => println("Got something weird: " + m + " of type " + m.getClass.toString) 
     } 
     } 
    } 
    } 

    abstract class Worker extends Actor { 
    def act { 
     RemoteActor.classLoader = getClass.getClassLoader 
     val master = select(masterNode, 'MasterProcess) 
     link(master) 
     master ! Connect 
    } 
    } 
} 

ここでは使用例です：私はこのプログラムを実行すると

object MyConnectionApp extends optional.Application { 

    case class MyConTest(hostname: String, port: Int) extends ConnectionTest(Node(hostname, port), port) { 
    case object MyMaster extends Master 
    case object MyWorker extends Worker 
    } 

    def main(master: Boolean) = { 
    if (master) 
     MyConTest("localhost", 2552).MyMaster start 
    else 
     MyConTest("localhost", 2552).MyWorker start 
    } 
} 

、出力が上記のようです。 MyWorkerからリモートで受信されたConnectメッセージは、アクトメソッドMyMasterのパターンマッチで認識されませんでした。 getClass.toStringが同じことを評価しても、どちらも同じではありません。これをどうすれば解決できますか？

[1]詳細：私は、多数のノードにわたってある種の並列計算のためのフレームワークを実装しています。もっと複雑なケースでは、実際にConnectionTestをParallelComputation[Data, Result]に置き換えたいと思います。ここで、DataとResultはタイプパラメータです。メッセージはまた、理想的には、私はこのデザインパターンとよく果たしているソリューションを希望

case object Computed(x: Data, y: Result) extends Message 

のように、これらのパラメータに依存するクラスが含まれます。

Answer 1

私はテストしていませんが、Messageの特性と実装（オブジェクトConnectを含む）をクラスConnectionTestに入れてはいけないと思います。それらをコンパニオンオブジェクトに入れることができます。それらをクラスに入れると、クラスConnectionTestを含む各インスタンスに対して別個のオブジェクトConnectが存在します（直列化のコンテキストでは、そのインスタンスへの参照があります）。

オブジェクトConnect異なるConnectionTestのインスタンスに属し、互いに一致しません。