All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class JavaGroups.JavaStack.RouterStub

java.lang.Object
   |
   +----JavaGroups.JavaStack.RouterStub

public class RouterStub

extends Object

RouterStub(String, int)

Creates a stub for a remote Router object.

Connect()

Establishes a connection to the router.

Disconnect()

Closes the socket and the input and output streams associated with it

Get(String)

Retrieves the membership (list of Addresses) for a given group.

main(String[])

Receive()

Receives a message from the router (blocking mode).

Reconnect()

Tries to establish connection to router.

Register(String)

Register this process with the routerb under groupname.

Send(Message)

Sends a message to the router.

 public RouterStub(String router_host,
                   int router_port)

Creates a stub for a remote Router object.

Parameters:

router_host - The name of the router's host

router_port - The router's port

 public Address Connect()

Establishes a connection to the router. The router will send my address (its peer address) back as an Address, which is subsequently returned to the caller. The reason for not using InetAddress.getLocalHost() or sock.getLocalAddress() is that this may not be permitted with certain security managers in case this code runs in an applet.

 public void Disconnect()

Closes the socket and the input and output streams associated with it

 public boolean Register(String groupname)

Register this process with the routerb under groupname.

Parameters:

groupname - The name of the group under which to register

Returns:

boolean False if connection down, true if registration successful.

 public List Get(String groupname)

Retrieves the membership (list of Addresses) for a given group. This is mainly used by the PING protocol to obtain its initial membership. This is used infrequently, so don't maintain socket for the entire time, but create/delete it on demand.

 public boolean Send(Message msg)

Sends a message to the router. Returns false if message cannot be sent (e.g. no connection to router, true otherwise.

 public Message Receive()

Receives a message from the router (blocking mode). If the connection is down, false is returned, otherwise true

 public synchronized boolean Reconnect()

Tries to establish connection to router. Tries until router is up again.

 public static void main(String args[])

All Packages  Class Hierarchy  This Package  Previous  Next  Index