| java.lang.Object
 org.jgroups.stack.GossipClient
| GossipClient | | public class GossipClient (Code) | | Local stub for clients to access one (or more) GossipRouters. Will use proprietary protocol
(using GossipData PDUs) based on TCP to connect to GossipRouter.
Requires JDK >= 1.3 due to the use of Timer.
author:
Bela Ban Oct 4 2001
version:
$Id: GossipClient.java,v 1.16 2006/10/25 08:23:58 belaban Exp $ |
| EXPIRY_TIME | | long EXPIRY_TIME(Code) | | |
| SOCKET_TIMEOUT | | final int SOCKET_TIMEOUT(Code) | | |
| log | | final protected Log log(Code) | | |
| refresher_enabled | | boolean refresher_enabled(Code) | | |
| timer_running | | boolean timer_running(Code) | | |
| GossipClient | | public GossipClient(IpAddress gossip_host, long expiry)(Code) | | Creates the GossipClient
Parameters:
gossip_host - The address and port of the host on which the GossipRouter is running
Parameters:
expiry - Interval (in msecs) for the refresher task |
| GossipClient | | public GossipClient(Vector gossip_hosts, long expiry)(Code) | | Creates the GossipClient
Parameters:
gossip_hosts - List of IpAddresses
Parameters:
expiry - Interval (in msecs) for the refresher task |
| _register | | void _register(String group, Address mbr)(Code) | | Registers the group|mbr with *all* GossipRouters.
|
| addGossipRouter | | public void addGossipRouter(IpAddress gossip_host)(Code) | | Adds a GossipRouter to be accessed.
|
| destroy | | public void destroy()(Code) | | |
| getMembers | | public List getMembers(String group)(Code) | | Returns all members of a given group
Parameters:
group - The group name List A list of Addresses |
| isRefresherEnabled | | public boolean isRefresherEnabled()(Code) | | |
| register | | public void register(String group, Address mbr)(Code) | | 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 GossipRouters that GossipClient is configured to access
|
| setRefresherEnabled | | public void setRefresherEnabled(boolean refresher_enabled)(Code) | | |
| usage | | static void usage()(Code) | | |
|
|