com.liferay.portal.cache.ehcache
Class JGroupsManager
java.lang.Object
com.liferay.portal.cache.ehcache.JGroupsManager
- All Implemented Interfaces:
- Remote, net.sf.ehcache.distribution.CacheManagerPeerProvider, net.sf.ehcache.distribution.CachePeer
public class JGroupsManager
- extends Object
- implements net.sf.ehcache.distribution.CacheManagerPeerProvider, net.sf.ehcache.distribution.CachePeer
See http://issues.liferay.com/browse/LPS-11061.
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JGroupsManager
public JGroupsManager(net.sf.ehcache.CacheManager cacheManager,
String clusterName,
String channelProperties)
dispose
public void dispose()
throws net.sf.ehcache.CacheException
- Specified by:
dispose in interface net.sf.ehcache.distribution.CacheManagerPeerProvider
- Throws:
net.sf.ehcache.CacheException
getBusLocalAddress
public org.jgroups.Address getBusLocalAddress()
getBusMembership
public List<org.jgroups.Address> getBusMembership()
getElements
public List getElements(List list)
- Specified by:
getElements in interface net.sf.ehcache.distribution.CachePeer
getGuid
public String getGuid()
- Specified by:
getGuid in interface net.sf.ehcache.distribution.CachePeer
getKeys
public List getKeys()
- Specified by:
getKeys in interface net.sf.ehcache.distribution.CachePeer
getName
public String getName()
- Specified by:
getName in interface net.sf.ehcache.distribution.CachePeer
getQuiet
public net.sf.ehcache.Element getQuiet(Serializable serializable)
- Specified by:
getQuiet in interface net.sf.ehcache.distribution.CachePeer
getScheme
public String getScheme()
- Specified by:
getScheme in interface net.sf.ehcache.distribution.CacheManagerPeerProvider
getTimeForClusterToForm
public long getTimeForClusterToForm()
- Specified by:
getTimeForClusterToForm in interface net.sf.ehcache.distribution.CacheManagerPeerProvider
getUrl
public String getUrl()
- Specified by:
getUrl in interface net.sf.ehcache.distribution.CachePeer
getUrlBase
public String getUrlBase()
- Specified by:
getUrlBase in interface net.sf.ehcache.distribution.CachePeer
handleNotification
public void handleNotification(Serializable serializable)
init
public void init()
- Specified by:
init in interface net.sf.ehcache.distribution.CacheManagerPeerProvider
listRemoteCachePeers
public List<JGroupsManager> listRemoteCachePeers(net.sf.ehcache.Ehcache ehcache)
- Specified by:
listRemoteCachePeers in interface net.sf.ehcache.distribution.CacheManagerPeerProvider
put
public void put(net.sf.ehcache.Element element)
- Specified by:
put in interface net.sf.ehcache.distribution.CachePeer
registerPeer
public void registerPeer(String string)
- Specified by:
registerPeer in interface net.sf.ehcache.distribution.CacheManagerPeerProvider
remove
public boolean remove(Serializable serializable)
- Specified by:
remove in interface net.sf.ehcache.distribution.CachePeer
removeAll
public void removeAll()
- Specified by:
removeAll in interface net.sf.ehcache.distribution.CachePeer
send
public void send(org.jgroups.Address address,
List eventMessages)
throws RemoteException
- Throws:
RemoteException
send
public void send(List eventMessages)
throws RemoteException
- Specified by:
send in interface net.sf.ehcache.distribution.CachePeer
- Throws:
RemoteException
unregisterPeer
public void unregisterPeer(String string)
- Specified by:
unregisterPeer in interface net.sf.ehcache.distribution.CacheManagerPeerProvider
handleJGroupsNotification
protected void handleJGroupsNotification(net.sf.ehcache.distribution.jgroups.JGroupSerializable jGroupSerializable)
toJGroupSerializable
protected net.sf.ehcache.distribution.jgroups.JGroupSerializable toJGroupSerializable(net.sf.ehcache.distribution.jgroups.JGroupEventMessage jGroupEventMessage)