Skip navigation links
com.oracle.cep.cluster.ha.adapter
Class BufferingQueueTrimmingAdapter
java.lang.Object
|
+--com.oracle.cep.cluster.ha.adapter.QueueTrimmingAdapter
|
+--com.oracle.cep.cluster.ha.adapter.BufferingQueueTrimmingAdapter
- public class BufferingQueueTrimmingAdapter
- extends QueueTrimmingAdapter
QueueTrimmingAdapter
that uses the BufferingQueueTrimmingStrategy
and a TimedTrimmableQueue
. The adapter can also be configued via JMX through the BufferingQueueTrimmingAdapterMBean
Fields inherited from class com.oracle.cep.cluster.ha.adapter.QueueTrimmingAdapter |
applicationIdentity, BECOMING_PRIMARY, BECOMING_SECONDARY, bundleContext, INITIALIZING, lock, log, PRIMARY, queue, queueLock, SECONDARY, stageIdentity, state, trimmingProtocol, trimmingStrategy, warmUpFinishTime, warmUpWindowMillis |
Methods inherited from class com.oracle.cep.cluster.ha.adapter.QueueTrimmingAdapter |
activateConfiguration, afterConfigurationActive, afterPropertiesSet, checkConfiguration, doInsert, getApplicationIdentity, getGroupName, getLastReceivedKey, getQueue, getStageIdentity, getState, getTrimmingProtocol, getWarmUpWindowMillis, isExactTrimming, isInitializing, isPrimary, isSecondary, onInsertEvent, onMembershipChange, rollbackConfiguration, setApplicationIdentity, setBundleContext, setEventSender, setExactTrimming, setGroupName, setQueue, setStageIdentity, setTrimmingProtocol, setTrimmingStrategy, setWarmUpWindowMillis, stateChange |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEFAULT_WINDOW_LENGTH_MILLIS
public static long DEFAULT_WINDOW_LENGTH_MILLIS
BufferingQueueTrimmingAdapter
public BufferingQueueTrimmingAdapter()
setWindowLength
public void setWindowLength(long window)
-
- See Also:
BufferingQueueTrimmingStrategy.setWindowLength(long)
getWindowLength
public long getWindowLength()
-
- See Also:
BufferingQueueTrimmingStrategy.getWindowLength()
checkConfiguration
public void checkConfiguration(BufferingQueueTrimmingAdapterConfig config)
-
- Overrides:
- checkConfiguration in class QueueTrimmingAdapter
rollbackConfiguration
public void rollbackConfiguration(BufferingQueueTrimmingAdapterConfig config)
-
- Overrides:
- rollbackConfiguration in class QueueTrimmingAdapter
activateAdapter
public void activateAdapter(BufferingQueueTrimmingAdapterConfig config)