Class Summary | |
class
|
JavaSerializer
(serv : Service) extends Serializer
|
case class
|
NamedSend
(val senderName : Symbol, val receiver : Symbol, val data : Array[Byte]) extends Product
|
class
|
NetKernel
(service : Service) extends AnyRef
|
case class
|
Node
(val address : java.lang.String, val port : Int) extends Product
This class represents a machine node on a TCP network.
|
class
|
Proxy
(node : Node, name : Symbol, kernel : NetKernel) extends Actor
|
case class
|
Reply
(val senderName : Symbol, val receiver : Symbol, val data : Array[Byte]) extends Product
|
case class
|
ReplyTo
(val a : Actor, val msg : Any) extends Product
|
case class
|
SendTo
(val a : Actor, val msg : Any) extends Product
|
abstract class
|
Serializer
(val service : Service) extends AnyRef
|
trait
|
Service
extends AnyRef
|
case class
|
SyncSend
(val senderName : Symbol, val receiver : Symbol, val data : Array[Byte]) extends Product
|
case class
|
SyncSendTo
(val a : Actor, val msg : Any, val receiver : Symbol) extends Product
|
class
|
TcpService
(port : Int) extends java.lang.Thread with Service
|
class
|
TcpServiceWorker
(parent : TcpService, so : java.net.Socket) extends java.lang.Thread with AnyRef
|
Object Summary | |
object
|
FreshNameCreator
extends AnyRef
|
object
|
RemoteActor
extends AnyRef
This object provides methods for creating, registering, and selecting remotely accessible actors. A remote actor is typically created like this: actor { alive(9010) register('myName, self) // behavior } It can be accessed by an actor running on a (possibly) different node by selecting it in the following way: actor { // ... val c = select(Node("127.0.0.1", 9010), 'myName) c ! msg // ... } |
object
|
TcpService
extends AnyRef
|
case object
|
Terminate
extends Product
|