ddf.catalog.pubsub

Class FanoutEventProcessor

java.lang.Object

ddf.catalog.pubsub.EventProcessorImpl

ddf.catalog.pubsub.FanoutEventProcessor

All Implemented Interfaces:

EventProcessor, 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, EQUATORIAL_RADIUS_IN_METERS, eventAdmin, 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 and Description
FanoutEventProcessor(org.osgi.framework.BundleContext bundleContext, org.osgi.service.event.EventAdmin eventAdmin, List<PreSubscriptionPlugin> preSubscription, List<PreDeliveryPlugin> preDelivery, CatalogFramework catalog)

Method Summary

Modifier and Type	Method and Description
void	destroy()
void	init()
void	notifyCreated(Metacard newMetacard) Notify this EventProcessor that a Metacard (or equivalent) has been created in a RemoteSource.
void	notifyDeleted(Metacard oldMetacard) Notify this EventProcessor that a Metacard (or equivalent) has been deleted in a RemoteSource.
void	notifyUpdated(Metacard newMetacard, Metacard oldMetacard) Notify this EventProcessor that a Metacard (or equivalent) has been updated in a RemoteSource.

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 Detail

FanoutEventProcessor

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

Method Detail

init

public void init()

Overrides:

init in class EventProcessorImpl

destroy

public void destroy()

Overrides:

destroy in class EventProcessorImpl

notifyCreated

public void notifyCreated(Metacard newMetacard)

Description copied from interface: EventProcessor

Notify this EventProcessor that a Metacard (or equivalent) has been created in a RemoteSource.

Implementations of this method must:

1. Call the PreDeliveryPlugin.processCreate(Metacard) method for all of the registered PreDeliveryPlugins
2. Call the DeliveryMethod.created(Metacard) method of the DeliveryMethod of matching Subscriptions with the new Metacard created.

Specified by:

notifyCreated in interface EventProcessor

Overrides:

notifyCreated in class EventProcessorImpl

Parameters:

newMetacard - the newly created Metacard

See Also:

RemoteSource, FederatedSource, ConnectedSource

notifyUpdated

public void notifyUpdated(Metacard newMetacard,
                          Metacard oldMetacard)

Description copied from interface: EventProcessor

Notify this EventProcessor that a Metacard (or equivalent) has been updated in a RemoteSource.

Implementations of this method must:

1. Call PreDeliveryPlugin.processUpdateHit(ddf.catalog.operation.Update) method of all registered PreDeliveryPlugins when a Metacard has been updated and the new version matches a Subscription
2. Call PreDeliveryPlugin.processUpdateMiss(ddf.catalog.operation.Update) method of all registered PreDeliveryPlugins when a Metacard has been updated and the new version matches a Subscription but the old version does not
3. Call all registered implementations of DeliveryMethod with the updated Metacard.

Specified by:

notifyUpdated in interface EventProcessor

Overrides:

notifyUpdated in class EventProcessorImpl

Parameters:

newMetacard - the new version of the Metacard

oldMetacard - the previous version of the Metacard (optional, pass null if not relevant)

See Also:

FederatedSource, RemoteSource, ConnectedSource

notifyDeleted

public void notifyDeleted(Metacard oldMetacard)

Description copied from interface: EventProcessor

Notify this EventProcessor that a Metacard (or equivalent) has been deleted in a RemoteSource.

Implementations of this method must:

If possible (that is, the Metacard is fully populated) call all active matching Subscriptions associated DeliveryMethod.deleted(Metacard) with the Metacard that was deleted. If impossible (this is, the Metacard only has Metacard.getId(), call all active Subscriptions.

Specified by:

notifyDeleted in interface EventProcessor

Overrides:

notifyDeleted in class EventProcessorImpl

Parameters:

oldMetacard - the deleted Metacard

See Also:

RemoteSource, FederatedSource, ConnectedSource