public abstract class LocalHost extends SerialHandles
It can be one or several local nodes hosted on local host. For most applications one should be enough but sometimes several can be useful as well.
Local host contains: remote hosts connected with this one
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.util.UUID,RemoteHost> |
remoteHosts
Hosts known to the provider
|
private NettyServer |
server
Server for current instance of LocalHost
|
id
Constructor and Description |
---|
LocalHost() |
Modifier and Type | Method and Description |
---|---|
private void |
createRequest(java.lang.String host,
int port,
SerialMsg msg) |
void |
disconnect() |
abstract <T> T |
get(java.lang.Class<T> klass,
java.lang.String name) |
protected <T> DataflowVariable<T> |
getPromise(java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<T>> registry,
java.lang.String name,
java.lang.String host,
int port,
SerialMsg requestMsg) |
SerialContext |
getSerialHost(java.util.UUID hostId,
java.lang.Object attachment) |
void |
onDisconnect(SerialContext host) |
abstract <T> void |
registerProxy(java.lang.Class<T> klass,
java.lang.String name,
T object) |
void |
startServer(java.lang.String host,
int port) |
void |
stopServer() |
add, finalizeHandle, get, getId, remove
protected final java.util.Map<java.util.UUID,RemoteHost> remoteHosts
private NettyServer server
public void disconnect()
public SerialContext getSerialHost(java.util.UUID hostId, java.lang.Object attachment)
getSerialHost
in class SerialHandles
public void onDisconnect(SerialContext host)
public abstract <T> void registerProxy(java.lang.Class<T> klass, java.lang.String name, T object)
public abstract <T> T get(java.lang.Class<T> klass, java.lang.String name)
public void startServer(java.lang.String host, int port)
public void stopServer()
private void createRequest(java.lang.String host, int port, SerialMsg msg)
protected <T> DataflowVariable<T> getPromise(java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<T>> registry, java.lang.String name, java.lang.String host, int port, SerialMsg requestMsg)