org.jgroups.stack
Class GossipClient
java.lang.Object
org.jgroups.stack.GossipClient
public class GossipClient
extends java.lang.Object
Local stub for clients to access one (or more) GossipServers. Will use proprietary protocol
(using GossipData PDUs) based on TCP to connect to GossipServer.
Requires JDK >= 1.3 due to the use of Timer.
- Make access to multiple GossipServer concurrent (1 thread/GossipServer).
log
protected final Log log
GossipClient
public GossipClient(Vector gossip_hosts,
long expiry)
Creates the GossipClient
gossip_hosts
- List of IpAddressesexpiry
- Interval (in msecs) for the refresher task
GossipClient
public GossipClient(IpAddress gossip_host,
long expiry)
Creates the GossipClient
gossip_host
- The address and port of the host on which the GossipServer is runningexpiry
- Interval (in msecs) for the refresher task
addGossipServer
public void addGossipServer(IpAddress gossip_host)
Adds a GossipServer to be accessed.
getMembers
public Vector getMembers(String group)
Returns all members of a given group
- Vector A list of Addresses
main
public static void main(String[] args)
register
public void register(String group,
Address mbr)
Adds the member to the given group. If the group already has an entry for the member,
its timestamp will be updated, preventing the cache cleaner from removing the entry.
The entry will be registered
with all GossipServers that GossipClient is configured to access
Copyright B) 1998-2005 Bela Ban. All Rights Reserved.