Liferay 6.2.0

com.liferay.portal.cache.cluster.clusterlink
Class BlockingPortalCacheClusterEventQueue

java.lang.Object
  extended by com.liferay.portal.cache.cluster.clusterlink.BlockingPortalCacheClusterEventQueue
All Implemented Interfaces:
PortalCacheClusterEventQueue

public class BlockingPortalCacheClusterEventQueue
extends Object
implements PortalCacheClusterEventQueue


Constructor Summary
BlockingPortalCacheClusterEventQueue()
           
 
Method Summary
 long coalescedCount()
           
 int pendingCount()
           
 void put(PortalCacheClusterEvent portalCacheClusterEvent)
           
 PortalCacheClusterEvent take()
           
 Set<PortalCacheClusterEvent> takeSnapshot()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BlockingPortalCacheClusterEventQueue

public BlockingPortalCacheClusterEventQueue()
Method Detail

coalescedCount

public long coalescedCount()
Specified by:
coalescedCount in interface PortalCacheClusterEventQueue

pendingCount

public int pendingCount()
Specified by:
pendingCount in interface PortalCacheClusterEventQueue

put

public void put(PortalCacheClusterEvent portalCacheClusterEvent)
         throws InterruptedException
Specified by:
put in interface PortalCacheClusterEventQueue
Throws:
InterruptedException

take

public PortalCacheClusterEvent take()
                             throws InterruptedException
Specified by:
take in interface PortalCacheClusterEventQueue
Throws:
InterruptedException

takeSnapshot

public Set<PortalCacheClusterEvent> takeSnapshot()
Specified by:
takeSnapshot in interface PortalCacheClusterEventQueue

Liferay 6.2.0