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.

Constructor Summary

EventCountingQueueTrimmingStrategy()

Method Summary
void	afterPropertiesSet()
long	getTrimmingInterval()
void	onProcessedEvent(java.lang.Object event)
void	onQueuedEvent(TrimmableQueue queue)
void	setDelegate(QueueTrimmingStrategy delegate)
void	setTrimmingInterval(long trimmingInterval) Set the interval at which events are trimmed.
void	validate(int trimCount, int messageInterval)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventCountingQueueTrimmingStrategy

public EventCountingQueueTrimmingStrategy()

Method Detail

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