Liferay 6.1.2-ce-ga3

com.liferay.portal.cache.ehcache
Class JGroupsManager

java.lang.Object
  extended by 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.


Constructor Summary
JGroupsManager(net.sf.ehcache.CacheManager cacheManager, String clusterName, String channelProperties)
           
 
Method Summary
 void dispose()
           
 org.jgroups.Address getBusLocalAddress()
           
 List<org.jgroups.Address> getBusMembership()
           
 List getElements(List list)
           
 String getGuid()
           
 List getKeys()
           
 String getName()
           
 net.sf.ehcache.Element getQuiet(Serializable serializable)
           
 String getScheme()
           
 long getTimeForClusterToForm()
           
 String getUrl()
           
 String getUrlBase()
           
protected  void handleJGroupsNotification(net.sf.ehcache.distribution.jgroups.JGroupEventMessage jGroupEventMessage)
           
 void handleNotification(Serializable serializable)
           
 void init()
           
 List<JGroupsManager> listRemoteCachePeers(net.sf.ehcache.Ehcache ehcache)
           
 void put(net.sf.ehcache.Element element)
           
 void registerPeer(String string)
           
 boolean remove(Serializable serializable)
           
 void removeAll()
           
 void send(org.jgroups.Address address, List eventMessages)
           
 void send(List eventMessages)
           
 void unregisterPeer(String string)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JGroupsManager

public JGroupsManager(net.sf.ehcache.CacheManager cacheManager,
                      String clusterName,
                      String channelProperties)
Method Detail

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.JGroupEventMessage jGroupEventMessage)

Liferay 6.1.2-ce-ga3