org.codice.ddf.catalog.async.processingframework.impl

Class InMemoryProcessingFramework

java.lang.Object

org.codice.ddf.catalog.async.processingframework.impl.InMemoryProcessingFramework

All Implemented Interfaces:

ProcessingFramework

public class InMemoryProcessingFramework
extends Object
implements ProcessingFramework

The InMemoryProcessingFramework processes requests using a thread pool and submits the results back to the CatalogFramework after processing is complete, when appropriate. If no changes are detected after processing, no results will be sent back to the CatalogFramework. Currently, partial updates are not supported, meaning that any results being returned by the InMemoryProcessingFramework will override the metadata in the catalog.

Constructor Summary

Constructors

Constructor and Description
InMemoryProcessingFramework(CatalogFramework catalogFramework, ExecutorService threadPool)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
void	setPostProcessPlugins(List<PostProcessPlugin> postProcessPlugins)
void	submitCreate(ProcessRequest<ProcessCreateItem> input) Submits a ProcessRequest to be processed by the ProcessingFramework.
void	submitDelete(ProcessRequest<ProcessDeleteItem> input) Submits a ProcessRequest to be processed by the ProcessingFramework.
void	submitUpdate(ProcessRequest<ProcessUpdateItem> input) Submits a ProcessRequest to be processed by the ProcessingFramework.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryProcessingFramework

public InMemoryProcessingFramework(CatalogFramework catalogFramework,
                                   ExecutorService threadPool)

Method Detail

cleanUp

public void cleanUp()

submitCreate

public void submitCreate(ProcessRequest<ProcessCreateItem> input)

Description copied from interface: ProcessingFramework

Submits a ProcessRequest to be processed by the ProcessingFramework. Processing on the ProcessRequest will never block.

Specified by:

submitCreate in interface ProcessingFramework

Parameters:

input - the ProcessRequest to be processed

submitUpdate

public void submitUpdate(ProcessRequest<ProcessUpdateItem> input)

Description copied from interface: ProcessingFramework

Submits a ProcessRequest to be processed by the ProcessingFramework. Processing on the ProcessRequest will never block.

Specified by:

submitUpdate in interface ProcessingFramework

Parameters:

input - the ProcessRequest to be processed

submitDelete

public void submitDelete(ProcessRequest<ProcessDeleteItem> input)

Description copied from interface: ProcessingFramework

Submits a ProcessRequest to be processed by the ProcessingFramework. Processing on the ProcessRequest will never block.

Specified by:

submitDelete in interface ProcessingFramework

Parameters:

input - the ProcessDeleteRequest to be processed

setPostProcessPlugins

public void setPostProcessPlugins(List<PostProcessPlugin> postProcessPlugins)