Package ddf.catalog.pubsub

Class FanoutEventProcessor

java.lang.Object

ddf.catalog.pubsub.EventProcessorImpl

ddf.catalog.pubsub.FanoutEventProcessor

All Implemented Interfaces:

ddf.catalog.event.EventProcessor, ddf.catalog.plugin.PostIngestPlugin, org.osgi.service.event.EventHandler

public class FanoutEventProcessor
extends EventProcessorImpl

Nested Class Summary

Nested classes/interfaces inherited from class ddf.catalog.pubsub.EventProcessorImpl

EventProcessorImpl.DateType

Field Summary

Fields inherited from class ddf.catalog.pubsub.EventProcessorImpl

bundleContext, catalog, ENTERING, EQUATORIAL_RADIUS_IN_METERS, eventAdmin, EXITING, preDelivery, preSubscription

Fields inherited from interface ddf.catalog.event.EventProcessor

EVENT_METACARD, EVENT_OLD_METACARD, EVENT_TIME, EVENTS_TOPIC_CREATED, EVENTS_TOPIC_DELETED, EVENTS_TOPIC_UPDATED

Constructor Summary

Constructors

Constructor	Description
FanoutEventProcessor(org.osgi.framework.BundleContext bundleContext, org.osgi.service.event.EventAdmin eventAdmin, List<ddf.catalog.plugin.PreSubscriptionPlugin> preSubscription, List<ddf.catalog.plugin.PreDeliveryPlugin> preDelivery, ddf.catalog.CatalogFramework catalog)

Method Summary

Modifier and Type	Method	Description
void	destroy()
void	init()
void	notifyCreated(ddf.catalog.data.Metacard newMetacard)
void	notifyDeleted(ddf.catalog.data.Metacard oldMetacard)
void	notifyUpdated(ddf.catalog.data.Metacard newMetacard, ddf.catalog.data.Metacard oldMetacard)

Methods inherited from class ddf.catalog.pubsub.EventProcessorImpl

createSubscription, createSubscription, deleteSubscription, handleEvent, postEvent, process, process, process, processEntry, updateSubscription

Methods inherited from class java.lang.Object

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

Constructor Details

FanoutEventProcessor

public FanoutEventProcessor(org.osgi.framework.BundleContext bundleContext,
 org.osgi.service.event.EventAdmin eventAdmin,
 List<ddf.catalog.plugin.PreSubscriptionPlugin> preSubscription,
 List<ddf.catalog.plugin.PreDeliveryPlugin> preDelivery,
 ddf.catalog.CatalogFramework catalog)

Method Details

init

public void init()

Overrides:

init in class EventProcessorImpl

destroy

public void destroy()

Overrides:

destroy in class EventProcessorImpl

notifyCreated

public void notifyCreated(ddf.catalog.data.Metacard newMetacard)

Specified by:

notifyCreated in interface ddf.catalog.event.EventProcessor

Overrides:

notifyCreated in class EventProcessorImpl

notifyUpdated

public void notifyUpdated(ddf.catalog.data.Metacard newMetacard,
 ddf.catalog.data.Metacard oldMetacard)

Specified by:

notifyUpdated in interface ddf.catalog.event.EventProcessor

Overrides:

notifyUpdated in class EventProcessorImpl

notifyDeleted

public void notifyDeleted(ddf.catalog.data.Metacard oldMetacard)

Specified by:

notifyDeleted in interface ddf.catalog.event.EventProcessor

Overrides:

notifyDeleted in class EventProcessorImpl