Skip navigation links

Package com.oracle.cep.cluster.ha.adapter

Interface Summary

DelegatingQueueTrimmingStrategy	QueueTrimmingStrategy that delegates to another QueueTrimmingStrategy.
HAAdapter
QueueTrimmingProtocol	Protocol to use for queue trimming.
QueueTrimmingStrategy	Strategy interface for the kind of queue trimming required by a QueueTrimmingAdapter.
TrimmableQueue	Simple Queue interface encapsulating only those methods required by QueueTrimmingAdapter

Class Summary
AtomicCounter
BroadcastQueueTrimmingAdapter	The BroadcastQueueTrimmingAdapter is intended for use by highly available CEP applications that need to guarantee that no output events are dropped when there is a failover, but which can tolerate duplicate output events.
BroadcastQueueTrimmingAdapterFactory
BufferingQueueTrimmingAdapter	QueueTrimmingAdapter that uses the BufferingQueueTrimmingStrategy and a TimedTrimmableQueue.
BufferingQueueTrimmingAdapterFactory
BufferingQueueTrimmingStrategy	QueueTrimmingStrategy that trims the backup queue based on a sliding window of events.
CorrelatedQueueTrimmingAdapter	Adapter that correlates an inbound buffer of events with a second source of the same event stream, outputting the buffer if correlation fails after some timed interval.
CorrelatedQueueTrimmingAdapterFactory
EventCountingQueueTrimmingStrategy	QueueTrimmingStrategy that trims the backup queue based on event counting.
EventIdentitySupport
EventWindowQueueTrimmingStrategy	Trim the backup queue based on a time window of events
NullTrimmingStrategy	QueueTrimmingStrategy that does nothing.
QueueTrimmingAdapter	This class implements an HA queue trimming adapter proxy.
QueueTrimmingAdapterFactory
SynchronizedTrimmableQueue	This implementation is synchronized, but maybe that's okay since it will cause the secondary to run a bit slower.
TimedTrimmableQueue	TrimmableQueue that records the entry time of events into the window and thus can be easily trimmed of older events.