public class RouterStub
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
RouterStub.ConnectionListener |
Modifier and Type | Field and Description |
---|---|
protected RouterStub.ConnectionListener |
conn_listener |
protected static org.apache.commons.logging.Log |
log |
Constructor and Description |
---|
RouterStub() |
RouterStub(java.lang.String router_host,
int router_port)
Creates a stub for a remote Router object.
|
Modifier and Type | Method and Description |
---|---|
void |
connect(java.lang.String groupname)
Register this process with the router under
groupname . |
void |
connect(java.lang.String groupname,
java.lang.String router_host,
int router_port) |
void |
disconnect()
Closes the socket and the input and output streams associated with it
|
void |
disconnect(boolean is_reconnect) |
java.util.List |
get(java.lang.String groupname)
Retrieves the membership (list of Addresses) for a given group.
|
java.net.InetAddress |
getBindAddress() |
Address |
getLocalAddress() |
java.lang.String |
getRouterHost() |
int |
getRouterPort() |
boolean |
isConnected() |
static void |
main(java.lang.String[] args) |
Message |
receive()
Receives a message from the router (blocking mode).
|
void |
reconnect() |
void |
reconnect(int max_attempts)
Tries to establish connection to router.
|
boolean |
send(Message msg,
java.lang.String groupname)
Sends a message to the router.
|
void |
setBindAddress(java.net.InetAddress bind_addr) |
void |
setConnectionListener(RouterStub.ConnectionListener conn_listener) |
void |
setRouterHost(java.lang.String router_host) |
void |
setRouterPort(int router_port) |
protected static final org.apache.commons.logging.Log log
protected RouterStub.ConnectionListener conn_listener
public RouterStub()
public RouterStub(java.lang.String router_host, int router_port)
router_host
- The name of the router's hostrouter_port
- The router's portpublic java.net.InetAddress getBindAddress()
public void setBindAddress(java.net.InetAddress bind_addr)
public java.lang.String getRouterHost()
public void setRouterHost(java.lang.String router_host)
public int getRouterPort()
public void setRouterPort(int router_port)
public boolean isConnected()
public void setConnectionListener(RouterStub.ConnectionListener conn_listener)
public Address getLocalAddress() throws java.net.SocketException
java.net.SocketException
public void connect(java.lang.String groupname) throws java.lang.Exception
groupname
.groupname
- The name of the group under which to registerjava.lang.Exception
public void connect(java.lang.String groupname, java.lang.String router_host, int router_port) throws java.lang.Exception
java.lang.Exception
public void disconnect()
public void disconnect(boolean is_reconnect)
public java.util.List get(java.lang.String groupname)
public boolean send(Message msg, java.lang.String groupname)
public Message receive() throws java.lang.Exception
java.lang.Exception
public void reconnect(int max_attempts) throws java.lang.Exception
java.lang.Exception
public void reconnect() throws java.lang.Exception
java.lang.Exception
public static void main(java.lang.String[] args)
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.