org.jgroups.stack

Class 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

todo: make access to multiple GossipServer concurrent (1 thread/GossipServer)

Author:
Bela Ban Oct 4 2001

Field Summary

protected Log
log

Constructor Summary

GossipClient(Vector gossip_hosts, long expiry)
Creates the GossipClient
GossipClient(IpAddress gossip_host, long expiry)
Creates the GossipClient

Method Summary

void
addGossipServer(IpAddress gossip_host)
Adds a GossipServer to be accessed.
Vector
getMembers(String group)
Returns all members of a given group
static void
main(String[] args)
void
register(String group, Address mbr)
Adds the member to the given group.
void
stop()

Field Details

log

protected Log log

Constructor Details

GossipClient

public GossipClient(Vector gossip_hosts,
                    long expiry)
Creates the GossipClient
Parameters:
gossip_hosts - List of IpAddresses
expiry - Interval (in msecs) for the refresher task

GossipClient

public GossipClient(IpAddress gossip_host,
                    long expiry)
Creates the GossipClient
Parameters:
gossip_host - The address and port of the host on which the GossipServer is running
expiry - Interval (in msecs) for the refresher task

Method Details

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
Parameters:
group - The group name
Returns:
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


stop

public void stop()

Copyright B) 2001,2002 www.jgroups.com . All Rights Reserved.