Package org.jgroups.stack
Class GossipClient
java.lang.Object
org.jgroups.stack.GossipClient
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.
- Version:
- $Id: GossipClient.java,v 1.18.2.4 2008/10/31 08:21:14 belaban Exp $
- Author:
- Bela Ban Oct 4 2001
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionGossipClient
(Vector<IpAddress> gossip_hosts, long expiry) Creates the GossipClientGossipClient
(Vector<IpAddress> gossip_hosts, long expiry, int sock_conn_timeout) GossipClient
(IpAddress gossip_host, long expiry) Creates the GossipClient -
Method Summary
Modifier and TypeMethodDescriptionvoid
addGossipRouter
(IpAddress gossip_host) Adds a GossipRouter to be accessed.void
destroy()
getMembers
(String group) Returns all members of a given grouplong
int
int
boolean
static void
void
Adds the member to the given group.void
setRefresherEnabled
(boolean refresher_enabled) void
setRefreshInterval
(long refresh_interval) void
setSocketConnectionTimeout
(int sock_conn_timeout) void
setSocketReadTimeout
(int sock_read_timeout) void
stop()
void
unregister
(String group, Address mbr)
-
Field Details
-
log
protected final org.apache.commons.logging.Log log
-
-
Constructor Details
-
GossipClient
Creates the GossipClient- Parameters:
gossip_host
- The address and port of the host on which the GossipRouter is runningexpiry
- Interval (in msecs) for the refresher task
-
GossipClient
Creates the GossipClient- Parameters:
gossip_hosts
- List of IpAddressesexpiry
- Interval (in msecs) for the refresher task
-
GossipClient
-
-
Method Details
-
isRefresherEnabled
public boolean isRefresherEnabled() -
setRefresherEnabled
public void setRefresherEnabled(boolean refresher_enabled) -
getSocketConnectionTimeout
public int getSocketConnectionTimeout() -
setSocketConnectionTimeout
public void setSocketConnectionTimeout(int sock_conn_timeout) -
getSocketReadTimeout
public int getSocketReadTimeout() -
setSocketReadTimeout
public void setSocketReadTimeout(int sock_read_timeout) -
getRefreshInterval
public long getRefreshInterval() -
setRefreshInterval
public void setRefreshInterval(long refresh_interval) -
stop
public void stop() -
destroy
public void destroy() -
addGossipRouter
Adds a GossipRouter to be accessed. -
register
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
-
unregister
-
getMembers
Returns all members of a given group- Parameters:
group
- The group name- Returns:
- List A list of Addresses
-
main
-