Skip navigation links
com.oracle.cep.cluster.ha.adapter
Class EventCountingQueueTrimmingStrategy
java.lang.Object
|
+--com.oracle.cep.cluster.ha.adapter.EventCountingQueueTrimmingStrategy
- public class EventCountingQueueTrimmingStrategy
- extends java.lang.Object
- implements DelegatingQueueTrimmingStrategy
QueueTrimmingStrategy
that trims the backup queue based on event counting. The queue is trimmed every getTrimmingInterval()
events.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
EventCountingQueueTrimmingStrategy
public EventCountingQueueTrimmingStrategy()
setTrimmingInterval
public void setTrimmingInterval(long trimmingInterval)
- Set the interval at which events are trimmed.
-
- Parameters:
trimmingInterval
- the trimming interval
getTrimmingInterval
public long getTrimmingInterval()
-
- Returns:
- the trimming interval
afterPropertiesSet
public void afterPropertiesSet()
onProcessedEvent
public void onProcessedEvent(java.lang.Object event)
onQueuedEvent
public void onQueuedEvent(TrimmableQueue queue)
validate
public void validate(int trimCount,
int messageInterval)
setDelegate
public void setDelegate(QueueTrimmingStrategy delegate)
-
- Specified by:
- setDelegate in interface DelegatingQueueTrimmingStrategy