Skip navigation links

com.oracle.cep.cluster.ha.adapter
Class QueueTrimmingAdapter.BasicQueueTrimmingProtocol

java.lang.Object
  |
  +--com.oracle.cep.cluster.ha.adapter.QueueTrimmingAdapter.BasicQueueTrimmingProtocol

Direct Known Subclasses:

QueueTrimmingAdapter.IdentityQueueTrimmingProtocol, QueueTrimmingAdapter.MonotonicQueueTrimmingProtocol

protected class QueueTrimmingAdapter.BasicQueueTrimmingProtocol

extends java.lang.Object

implements QueueTrimmingProtocol

Field Summary

protected EventIdentitySupport	eventIdentity
protected java.lang.Object	trimmingKey

Constructor Summary

QueueTrimmingAdapter.BasicQueueTrimmingProtocol(EventIdentitySupport eventIdentity)

Method Summary
boolean	disableEventTrimming(java.lang.Object event)
void	enableEventTrimming(java.lang.Object trimmingKey)
boolean	eventTrimmingDisabled()
boolean	eventTrimmingEnabled()
java.lang.Object	getTrimmingKey()
void	resetEventTrimming()
boolean	trimLastEvent()
int	trimQueue(java.lang.Object key)

Methods inherited from class java.lang.Object

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

Field Detail

trimmingKey

protected java.lang.Object trimmingKey

eventIdentity

protected EventIdentitySupport eventIdentity

Constructor Detail

QueueTrimmingAdapter.BasicQueueTrimmingProtocol

public QueueTrimmingAdapter.BasicQueueTrimmingProtocol(EventIdentitySupport eventIdentity)

Method Detail

trimQueue

public int trimQueue(java.lang.Object key)

Specified by:

trimQueue in interface QueueTrimmingProtocol

disableEventTrimming

public boolean disableEventTrimming(java.lang.Object event)

Specified by:

disableEventTrimming in interface QueueTrimmingProtocol

trimLastEvent

public boolean trimLastEvent()

Specified by:

trimLastEvent in interface QueueTrimmingProtocol

eventTrimmingDisabled

public boolean eventTrimmingDisabled()

Specified by:

eventTrimmingDisabled in interface QueueTrimmingProtocol

enableEventTrimming

public void enableEventTrimming(java.lang.Object trimmingKey)

Specified by:

enableEventTrimming in interface QueueTrimmingProtocol

eventTrimmingEnabled

public boolean eventTrimmingEnabled()

Specified by:

eventTrimmingEnabled in interface QueueTrimmingProtocol

getTrimmingKey

public java.lang.Object getTrimmingKey()

Specified by:

getTrimmingKey in interface QueueTrimmingProtocol

resetEventTrimming

public void resetEventTrimming()

Specified by:

resetEventTrimming in interface QueueTrimmingProtocol