public final class MulticastRMICacheManagerPeerProvider extends RMICacheManagerPeerProvider implements CacheManagerPeerProvider
Modifier and Type | Class and Description |
---|---|
protected static class |
MulticastRMICacheManagerPeerProvider.CachePeerEntry
Entry containing a looked up CachePeer and date
|
Modifier and Type | Field and Description |
---|---|
protected static int |
SHORT_DELAY
One tenth of a second, in ms
|
cacheManager, peerUrls
Constructor and Description |
---|
MulticastRMICacheManagerPeerProvider(CacheManager cacheManager,
InetAddress groupMulticastAddress,
Integer groupMulticastPort,
Integer timeToLive,
InetAddress hostAddress)
Creates and starts a multicast peer provider
|
Modifier and Type | Method and Description |
---|---|
void |
dispose()
Shutdown the heartbeat
|
MulticastKeepaliveHeartbeatReceiver |
getHeartBeatReceiver() |
MulticastKeepaliveHeartbeatSender |
getHeartBeatSender() |
protected long |
getStaleTime()
The time after which an unrefreshed peer provider entry is considered stale.
|
long |
getTimeForClusterToForm()
Time for a cluster to form.
|
void |
init()
Notifies providers to initialise themselves.
|
List |
listRemoteCachePeers(Ehcache cache) |
void |
registerPeer(String rmiUrl)
Register a new peer, but only if the peer is new, otherwise the last seen timestamp is updated.
|
protected boolean |
stale(Date date)
Whether the entry should be considered stale.
|
getCacheManager, getScheme, lookupRemoteCachePeer, unregisterPeer
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getScheme, unregisterPeer
protected static final int SHORT_DELAY
public MulticastRMICacheManagerPeerProvider(CacheManager cacheManager, InetAddress groupMulticastAddress, Integer groupMulticastPort, Integer timeToLive, InetAddress hostAddress)
groupMulticastAddress
- 224.0.0.1 to 239.255.255.255 e.g. 230.0.0.1groupMulticastPort
- 1025 to 65536 e.g. 4446hostAddress
- the address of the interface to use for sending and receiving multicast. May be null.public final void init() throws CacheException
init
in interface CacheManagerPeerProvider
init
in class RMICacheManagerPeerProvider
CacheException
public final void registerPeer(String rmiUrl)
registerPeer
in interface CacheManagerPeerProvider
registerPeer
in class RMICacheManagerPeerProvider
rmiUrl
- public final List listRemoteCachePeers(Ehcache cache) throws CacheException
listRemoteCachePeers
in interface CacheManagerPeerProvider
listRemoteCachePeers
in class RMICacheManagerPeerProvider
CachePeer
peers, excluding the local peer.CacheException
public final void dispose()
dispose
in interface CacheManagerPeerProvider
dispose
in class RMICacheManagerPeerProvider
public long getTimeForClusterToForm()
getTimeForClusterToForm
in interface CacheManagerPeerProvider
protected long getStaleTime()
protected final boolean stale(Date date)
stale
in class RMICacheManagerPeerProvider
date
- the date the entry was createdpublic MulticastKeepaliveHeartbeatReceiver getHeartBeatReceiver()
public MulticastKeepaliveHeartbeatSender getHeartBeatSender()
Copyright © 2003–2016 Terracotta, Inc.. All rights reserved.