public class EPNActiveCollectionSource extends ActiveCollectionSource
Modifier and Type | Class and Description |
---|---|
class |
EPNActiveCollectionSource.EPNACSNotificationListener
This class handles the events from the EPN.
|
ActiveCollectionSource.Aggregator, ActiveCollectionSource.DerivedDefinition
Constructor and Description |
---|
EPNActiveCollectionSource() |
Modifier and Type | Method and Description |
---|---|
protected void |
aggregateEvents(String subject,
EventList events)
This method processes the notification to aggregate information over a
particular duration.
|
void |
close()
This method closes the active collection source.
|
String |
getSubject()
This method gets the subject.
|
void |
init(ActiveCollectionContext context)
This method initializes the active collection source.
|
protected boolean |
isRelevant(String subject)
This method determines whether the notification is relevant for this
active collection source.
|
protected void |
preInit()
This method pre-initializes the active collection source
in situations where it needs to be initialized before
registration with the manager.
|
protected void |
processNotification(String subject,
EventList events)
This method processes the notification to update the active collection
accordingly.
|
void |
setSubject(String subject)
This method sets the subject.
|
aggregateEvent, getActiveChangeListeners, getActiveCollection, getAggregationDuration, getAggregationScript, getDerived, getDerivedActiveCollections, getFactory, getGroupBy, getGroupedEvents, getHighWaterMark, getItemExpiration, getLazy, getMaintenanceScript, getMaxItems, getName, getProperties, getScheduledInterval, getScheduledScript, getType, getVariables, getVisibility, hasActiveCollection, insert, maintainEntry, publishAggregateEvents, remove, setActiveChangeListeners, setActiveCollection, setAggregationDuration, setAggregationScript, setDerived, setFactory, setGroupBy, setHighWaterMark, setItemExpiration, setLazy, setMaintenanceScript, setMaxItems, setName, setProperties, setScheduledInterval, setScheduledScript, setType, setVisibility, update
public void setSubject(String subject)
subject
- The subjectpublic String getSubject()
public void init(ActiveCollectionContext context) throws Exception
init
in class ActiveCollectionSource
context
- The contextException
- Failed to initialize sourceprotected void preInit() throws Exception
preInit
in class ActiveCollectionSource
Exception
- Failed to pre-initializeprotected void aggregateEvents(String subject, EventList events)
subject
- The subjectevents
- The list of events to be processedpublic void close() throws Exception
close
in class ActiveCollectionSource
Exception
- Failed to close sourceprotected boolean isRelevant(String subject)
subject
- The subjectCopyright © 2013-2015 JBoss by Red Hat. All Rights Reserved.