org.codice.ddf.registry.identification

Class RegistryIdPostIngestPlugin

java.lang.Object

org.codice.ddf.registry.identification.RegistryIdPostIngestPlugin

All Implemented Interfaces:

PostIngestPlugin

public class RegistryIdPostIngestPlugin
extends Object
implements PostIngestPlugin

The RegistryIdPostIngestPlugin collects a set of registry-ids that are currently in the system and makes them available to the IdentificationPlugin for duplication checking.

Initially the catalog is queried to initialize the set of registry-ids. After that the list is maintained by the process methods for create and delete responses.

Constructor Summary

Constructors

Constructor and Description
RegistryIdPostIngestPlugin()
RegistryIdPostIngestPlugin(Security security)

Method Summary

Modifier and Type	Method and Description
void	destroy()
Set<String>	getLocalRegistryIds()
Set<String>	getRegistryIds()
Set<String>	getRemoteMetacardIds()
void	init() Init method initializes the id sets from the catalog.
CreateResponse	process(CreateResponse input) Processes the CreateResponse.
DeleteResponse	process(DeleteResponse input) Processes the DeleteResponse.
UpdateResponse	process(UpdateResponse input) Processes the UpdateResponse.
void	setCatalogFramework(CatalogFramework framework)
void	setExecutorService(ScheduledExecutorService executorService)
void	setFilterBuilder(FilterBuilder filterBuilder)

Methods inherited from class java.lang.Object

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

Constructor Detail

RegistryIdPostIngestPlugin

public RegistryIdPostIngestPlugin()

RegistryIdPostIngestPlugin

public RegistryIdPostIngestPlugin(Security security)

Method Detail

getRegistryIds

public Set<String> getRegistryIds()

getRemoteMetacardIds

public Set<String> getRemoteMetacardIds()

getLocalRegistryIds

public Set<String> getLocalRegistryIds()

process

public CreateResponse process(CreateResponse input)
                       throws PluginExecutionException

Description copied from interface: PostIngestPlugin

Processes the CreateResponse.

Specified by:

process in interface PostIngestPlugin

Parameters:

input - the CreateResponse to process

Returns:

the value of the processed CreateResponse to pass to the next PostIngestPlugin, or if this is the last PostIngestPlugin to be called

Throws:

PluginExecutionException - thrown when an error occurs during processing

process

public UpdateResponse process(UpdateResponse input)
                       throws PluginExecutionException

Description copied from interface: PostIngestPlugin

Processes the UpdateResponse.

Specified by:

process in interface PostIngestPlugin

Parameters:

input - the UpdateResponse to process

Returns:

the value of the processed UpdateResponse to pass to the next PostIngestPlugin, or if this is the last PostIngestPlugin to be called

Throws:

PluginExecutionException - thrown when an error occurs during processing

process

public DeleteResponse process(DeleteResponse input)
                       throws PluginExecutionException

Description copied from interface: PostIngestPlugin

Processes the DeleteResponse.

Specified by:

process in interface PostIngestPlugin

Parameters:

input - the DeleteResponse to process

Returns:

the value of the processed DeleteResponse to pass to the next PostIngestPlugin, or if this is the last PostIngestPlugin to be called

Throws:

PluginExecutionException - thrown when an error occurs during processing

init

public void init()

Init method initializes the id sets from the catalog. If the catalog is not available it will retry later.

destroy

public void destroy()

setFilterBuilder

public void setFilterBuilder(FilterBuilder filterBuilder)

setCatalogFramework

public void setCatalogFramework(CatalogFramework framework)

setExecutorService

public void setExecutorService(ScheduledExecutorService executorService)