groovyx.gpars.remote
Class LocalNode

java.lang.Object
  groovyx.gpars.remote.LocalNode

public class LocalNode
extends java.lang.Object

Representation of local node

Author:

Alex Tkachman

Field Summary

private java.util.UUID	id
private java.util.List<RemoteNodeDiscoveryListener>	listeners
private LocalHost	localHost
private Actor	mainActor
private java.util.concurrent.ThreadPoolExecutor	scheduler

Constructor Summary

LocalNode()

LocalNode(LocalHost provider)

LocalNode(LocalHost provider, java.lang.Runnable runnable)

LocalNode(java.lang.Runnable runnable)

Method Summary

void	addDiscoveryListener(groovy.lang.Closure listener)
void	addDiscoveryListener(RemoteNodeDiscoveryListener listener)
void	connect()
void	connect(LocalHost provider)
void	disconnect()
java.util.UUID	getId()
SerialHandles	getLocalHost()
Actor	getMainActor()
java.util.concurrent.Executor	getScheduler()
void	onConnect(RemoteNode node)
void	onDisconnect(RemoteNode node)
void	removeDiscoveryListener(RemoteNodeDiscoveryListener listener)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

listeners

private final java.util.List<RemoteNodeDiscoveryListener> listeners

scheduler

private final java.util.concurrent.ThreadPoolExecutor scheduler

mainActor

private final Actor mainActor

id

private final java.util.UUID id

localHost

private final LocalHost localHost

Constructor Detail

LocalNode

public LocalNode()

LocalNode

public LocalNode(java.lang.Runnable runnable)

LocalNode

public LocalNode(LocalHost provider)

LocalNode

public LocalNode(LocalHost provider,
                 java.lang.Runnable runnable)

Method Detail

connect

public void connect()

connect

public void connect(LocalHost provider)

disconnect

public void disconnect()

addDiscoveryListener

public void addDiscoveryListener(RemoteNodeDiscoveryListener listener)

addDiscoveryListener

public void addDiscoveryListener(groovy.lang.Closure listener)

removeDiscoveryListener

public void removeDiscoveryListener(RemoteNodeDiscoveryListener listener)

onConnect

public void onConnect(RemoteNode node)

onDisconnect

public void onDisconnect(RemoteNode node)

getMainActor

public Actor getMainActor()

getScheduler

public java.util.concurrent.Executor getScheduler()

getId

public java.util.UUID getId()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getLocalHost

public SerialHandles getLocalHost()