Skip navigation links

com.oracle.cep.cluster.ha.adapter
Class CorrelatedQueueTrimmingAdapter

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

public class CorrelatedQueueTrimmingAdapter

extends QueueTrimmingAdapter

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. Correlated events are trimmed from the queue. Correlated events are assumed to be in-order, if the secondary source reorders events then this adapter will fail. <p/> This adapter needs to be initialized through setCorrelatedSource(com.bea.wlevs.ede.spi.EventManagerAccessor) which corresponds to the source of correlating events.

Inner classes inherited from class com.oracle.cep.cluster.ha.adapter.QueueTrimmingAdapter

QueueTrimmingAdapter.BasicQueueTrimmingProtocol, QueueTrimmingAdapter.IdentityQueueTrimmingProtocol, QueueTrimmingAdapter.MonotonicQueueTrimmingProtocol

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

Constructor Summary

CorrelatedQueueTrimmingAdapter()

Method Summary
void	activateConfiguration(CorrelatedQueueTrimmingAdapterConfig config)
void	afterPropertiesSet()
void	checkConfiguration(CorrelatedQueueTrimmingAdapterConfig config)
java.lang.String	getEventType()
EventTypeRepository	getEventTypeRepository()
long	getFailOverDelay()
void	onCorrelatingInsertEvent(java.lang.Object event)
void	onMembershipChange(Server server, Configuration configuration) Schedule the failover handling into the future so as to accomodate correlating events that might take a while to reach us.
void	processMembershipChange(Server server, Configuration configuration)
void	rollbackConfiguration(CorrelatedQueueTrimmingAdapterConfig config)
void	setCorrelatedSource(com.bea.wlevs.ede.spi.EventManagerAccessor source) Set the event source that will be used to correlate against.
void	setEventType(java.lang.String eventType)
void	setEventTypeRepository(EventTypeRepository eventTypeRepository)
void	setFailOverDelay(long failOverDelay) Set the delay timeout that is used to decide how soon after failover correlation should restart.
void	setKeyClass(java.lang.Class keyClass)
void	setKeyProperties(java.lang.String keyProperties)

Methods inherited from class com.oracle.cep.cluster.ha.adapter.QueueTrimmingAdapter

activateConfiguration, afterConfigurationActive, checkConfiguration, doInsert, getApplicationIdentity, getGroupName, getLastReceivedKey, getQueue, getStageIdentity, getState, getTrimmingProtocol, getWarmUpWindowMillis, isExactTrimming, isInitializing, isPrimary, isSecondary, onInsertEvent, 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

Constructor Detail

CorrelatedQueueTrimmingAdapter

public CorrelatedQueueTrimmingAdapter()

Method Detail

setCorrelatedSource

public void setCorrelatedSource(com.bea.wlevs.ede.spi.EventManagerAccessor source)

Set the event source that will be used to correlate against. Events seen from this source will be purged from the trimming queue. Events still in the queue at failover will be replayed.

Parameters:

source - the source of events.

setKeyClass

public void setKeyClass(java.lang.Class keyClass)

setKeyProperties

public void setKeyProperties(java.lang.String keyProperties)

getEventType

public java.lang.String getEventType()

setEventType

public void setEventType(java.lang.String eventType)

getEventTypeRepository

public EventTypeRepository getEventTypeRepository()

setEventTypeRepository

public void setEventTypeRepository(EventTypeRepository eventTypeRepository)

onCorrelatingInsertEvent

public void onCorrelatingInsertEvent(java.lang.Object event)

afterPropertiesSet

public void afterPropertiesSet()

Overrides:

afterPropertiesSet in class QueueTrimmingAdapter

getFailOverDelay

public long getFailOverDelay()

Returns:

the failover delay in milliseconds.

setFailOverDelay

public void setFailOverDelay(long failOverDelay)

Set the delay timeout that is used to decide how soon after failover correlation should restart.

Parameters:

failOverDelay - in milliseconds

onMembershipChange

public void onMembershipChange(Server server,
                               Configuration configuration)

Schedule the failover handling into the future so as to accomodate correlating events that might take a while to reach us.

Overrides:

onMembershipChange in class QueueTrimmingAdapter

See Also:

GroupMembershipListener.onMembershipChange(com.bea.wlevs.ede.api.cluster.Server, com.bea.wlevs.ede.api.cluster.Configuration)

processMembershipChange

public void processMembershipChange(Server server,
                                    Configuration configuration)

checkConfiguration

public void checkConfiguration(CorrelatedQueueTrimmingAdapterConfig config)

Overrides:

checkConfiguration in class QueueTrimmingAdapter

activateConfiguration

public void activateConfiguration(CorrelatedQueueTrimmingAdapterConfig config)

Overrides:

activateConfiguration in class QueueTrimmingAdapter

rollbackConfiguration

public void rollbackConfiguration(CorrelatedQueueTrimmingAdapterConfig config)

Overrides:

rollbackConfiguration in class QueueTrimmingAdapter