Package | Description |
---|---|
groovyx.gpars.actor |
This package holds classes forming the public actor API.
|
groovyx.gpars.actor.impl |
This package holds classes some non-public aspects of actor implementation.
|
groovyx.gpars.dataflow.expression | |
groovyx.gpars.remote |
This package holds classes implementing the remote actors functionality.
|
groovyx.gpars.remote.message |
This package holds message classes for the remote actors implementation.
|
groovyx.gpars.remote.netty |
This package holds implementation-specific classes implementing the remote actors functionality on top of Netty.
|
groovyx.gpars.serial |
This package holds classes used for actor identification in the network.
|
Modifier and Type | Method and Description |
---|---|
void |
Actor.RemoteActor.StopActorMsg.execute(RemoteConnection conn) |
void |
Actor.RemoteActor.TerminateActorMsg.execute(RemoteConnection conn) |
Modifier and Type | Method and Description |
---|---|
void |
MessageStream.SendTo.execute(RemoteConnection conn) |
Modifier and Type | Method and Description |
---|---|
void |
DataflowExpression.BindDataflow.execute(RemoteConnection conn)
Performs the actual bind on the remote host
|
Modifier and Type | Field and Description |
---|---|
private java.util.ArrayList<RemoteConnection> |
RemoteHost.connections |
Modifier and Type | Method and Description |
---|---|
RemoteConnection |
RemoteHost.getConnection() |
Modifier and Type | Method and Description |
---|---|
void |
RemoteHost.addConnection(RemoteConnection connection) |
void |
RemoteHost.removeConnection(RemoteConnection connection) |
Modifier and Type | Method and Description |
---|---|
void |
NodeConnectedMsg.execute(RemoteConnection conn) |
void |
NodeDisconnectedMsg.execute(RemoteConnection conn) |
Modifier and Type | Class and Description |
---|---|
class |
NettyRemoteConnection
Connection using Netty
|
Modifier and Type | Field and Description |
---|---|
private RemoteConnection |
NettyHandler.connection |
private RemoteConnection |
RemoteObjectDecoder.connection |
private RemoteConnection |
RemoteObjectEncoder.connection |
Constructor and Description |
---|
RemoteObjectDecoder(RemoteConnection connection)
Creates a new encoder.
|
RemoteObjectEncoder(RemoteConnection connection)
Creates a new encoder.
|
Modifier and Type | Method and Description |
---|---|
void |
SerialHandle.RemoteSerialHandle.ReleaseHandle.execute(RemoteConnection conn) |
void |
SerialMsg.execute(RemoteConnection conn) |