com.liferay.portal.cache.cluster.clusterlink
Class BlockingPortalCacheClusterEventQueue
java.lang.Object
com.liferay.portal.cache.cluster.clusterlink.BlockingPortalCacheClusterEventQueue
- All Implemented Interfaces:
- PortalCacheClusterEventQueue
public class BlockingPortalCacheClusterEventQueue
- extends Object
- implements PortalCacheClusterEventQueue
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BlockingPortalCacheClusterEventQueue
public BlockingPortalCacheClusterEventQueue()
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