public class SpreadWrapper extends java.lang.Object implements RSBObject
Constructor and Description |
---|
SpreadWrapper()
Create a new Manager, assuming a spread daemon on localhost, port 4803.
|
SpreadWrapper(java.lang.String spreadhost,
int port)
Create a new Manager using the specified connection data for the Spread
network.
|
SpreadWrapper(java.lang.String spreadhost,
int port,
boolean sendOnly) |
Modifier and Type | Method and Description |
---|---|
void |
activate()
Activates all network resources that belong to a specific object.
|
protected void |
checkConnection() |
void |
deactivate()
Deactivate all network resources that are owned by a specific object in
order to reactivate it.
|
protected void |
finalize() |
java.lang.String |
getPrivateGroup() |
java.net.InetAddress |
getSpreadhost() |
rsb.transport.spread.SpreadWrapper.State |
getStatus() |
boolean |
isActive()
Tells wether this class is currently active or not.
|
protected boolean |
isConnectionLost() |
boolean |
isUseTcpNoDelay() |
void |
join(java.lang.String group) |
void |
leave(java.lang.String type) |
boolean |
send(DataMessage msg) |
void |
setConnectionLost(boolean connectionLost) |
void |
setStatus(rsb.transport.spread.SpreadWrapper.State status) |
void |
setUseTcpNoDelay(boolean useTcpNoDelay) |
public SpreadWrapper()
public SpreadWrapper(java.lang.String spreadhost, int port) throws InitializeException, java.net.UnknownHostException
spreadhost
- hostname of the machine the spread daemon is running onport
- for the spread daemonInitializeException
java.net.UnknownHostException
public SpreadWrapper(java.lang.String spreadhost, int port, boolean sendOnly) throws InitializeException, java.net.UnknownHostException
InitializeException
java.net.UnknownHostException
public rsb.transport.spread.SpreadWrapper.State getStatus()
public void setStatus(rsb.transport.spread.SpreadWrapper.State status)
status
- the status to setpublic java.net.InetAddress getSpreadhost()
public boolean isUseTcpNoDelay()
public void setUseTcpNoDelay(boolean useTcpNoDelay)
useTcpNoDelay
- the useTcpNoDelay to setpublic void setConnectionLost(boolean connectionLost)
connectionLost
- the connectionLost to setpublic void join(java.lang.String group) throws SpreadException
SpreadException
protected boolean isConnectionLost()
protected void checkConnection()
public boolean send(DataMessage msg)
public void deactivate() throws RSBException
RSBObject
deactivate
in interface RSBObject
RSBException
public void leave(java.lang.String type)
public void activate() throws InitializeException
RSBObject
activate
in interface RSBObject
InitializeException
public boolean isActive()
RSBObject
public java.lang.String getPrivateGroup()
protected void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable