Skip navigation links

Oracle Fusion Middleware Java API Reference for Oracle Complex Event Processing
11g Release 1 (11.1.1.4.0)

E14303-04
FRAMES    NO FRAMES
DETAIL:  FIELD | CONSTR | METHOD


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

Overview  Package   Class   Use  Tree  Deprecated  Index  Help 
Copyright © 2007, 2011 Oracle and/or its affiliates. All rights reserved.
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES
SUMMARY:  INNER | FIELD | CONSTR | METHOD DETAIL:  FIELD | CONSTR | METHOD