org.codice.ddf.registry.api.impl

Class RegistryStoreImpl

java.lang.Object

ddf.catalog.util.impl.DescribableImpl

ddf.catalog.util.impl.MaskableImpl

org.codice.ddf.spatial.ogc.csw.catalog.common.source.AbstractCswSource

org.codice.ddf.spatial.ogc.csw.catalog.common.source.AbstractCswStore

org.codice.ddf.registry.api.impl.RegistryStoreImpl

All Implemented Interfaces:

ResourceReader, ConfiguredService, CatalogStore, ConnectedSource, FederatedSource, RemoteSource, Source, Maskable, Describable, RegistryStore

public class RegistryStoreImpl
extends AbstractCswStore
implements RegistryStore

Field Summary

Fields

Modifier and Type	Field and Description
static String	AUTO_PUSH
static String	ID
static String	PULL_ALLOWED_PROPERTY
static String	PUSH_ALLOWED_PROPERTY
static String	REGISTRY_URL

Fields inherited from class org.codice.ddf.spatial.ogc.csw.catalog.common.source.AbstractCswStore

cswTransactionWriter, schemaTransformerManager

Fields inherited from class org.codice.ddf.spatial.ogc.csw.catalog.common.source.AbstractCswSource

availabilityPollFuture, capabilities, configurationPid, CONNECTION_TIMEOUT_PROPERTY, COORDINATE_ORDER_PROPERTY, CSW_SERVER_ERROR, cswFilterDelegate, cswSourceConfiguration, cswTransformConverter, CSWURL_PROPERTY, DISABLE_CN_CHECK_PROPERTY, EVENT_SERVICE_ADDRESS, factory, filterAdapter, filterBuilder, filterlessSubscriptionId, FORCE_SPATIAL_FILTER_PROPERTY, forceSpatialFilter, getRecordsTypeProvider, ID_PROPERTY, IS_CQL_FORCED_PROPERTY, jaxbElementClassMap, jaxbElementClassNames, METACARD_MAPPINGS_PROPERTY, NO_FORCE_SPATIAL_FILTER, OUTPUT_SCHEMA_PROPERTY, PASSWORD_PROPERTY, POLL_INTERVAL_PROPERTY, QUERY_TYPE_NAME_PROPERTY, QUERY_TYPE_NAMESPACE_PROPERTY, RECEIVE_TIMEOUT_PROPERTY, REGISTER_FOR_EVENTS, SECURITY_ATTRIBUTES_PROPERTY, securityManager, subscribeClientFactory, USE_POS_LIST_PROPERTY, USERNAME_PROPERTY

Constructor Summary

Constructors

Constructor and Description
RegistryStoreImpl(org.osgi.framework.BundleContext context, CswSourceConfiguration cswSourceConfiguration, com.thoughtworks.xstream.converters.Converter provider, SecureCxfClientFactory factory, EncryptionService encryptionService)
RegistryStoreImpl(EncryptionService encryptionService)

Method Summary

Modifier and Type	Method and Description
CreateResponse	create(CreateRequest request) Publishes a list of Metacard objects into the catalog.
DeleteResponse	delete(DeleteRequest request) Deletes records specified by a list of attribute values such as an id attribute.
protected Map<String,Consumer<Object>>	getAdditionalConsumers()
protected AvailabilityCommand	getAvailabilityCommand()
String	getRegistryId() Indicates the Id associated with this registry
boolean	isAutoPush() Indicates if the identity node should be automatically pushed to another registry store
boolean	isPullAllowed() Indicates if read operations are allowed on this registry
boolean	isPushAllowed() Indicates if write operations are allowed on this registry
SourceResponse	query(QueryRequest request)
void	setAutoPush(boolean autoPush)
void	setConfigAdmin(org.osgi.service.cm.ConfigurationAdmin config)
void	setMetacardMarshaller(MetacardMarshaller metacardMarshaller)
void	setMetaTypeService(org.osgi.service.metatype.MetaTypeService metaTypeService)
void	setPullAllowed(boolean pullAllowed)
void	setPushAllowed(boolean pushAllowed)
void	setRegistryId(String registryId)
void	setRegistryUrl(String registryUrl)
UpdateResponse	update(UpdateRequest request) Updates a list of Metacard records.

Methods inherited from class org.codice.ddf.spatial.ogc.csw.catalog.common.source.AbstractCswStore

getCswTransactionWriter, initProviders, setCswTransactionWriter, setSchemaTransformerManager, validateOperation

Methods inherited from class org.codice.ddf.spatial.ogc.csw.catalog.common.source.AbstractCswSource

addSourceMonitor, availabilityChanged, configureCswSource, createResults, destroy, getCapabilities, getConfigurationPid, getConnectionTimeout, getContentTypes, getCswTransformConverter, getDescription, getForceSpatialFilter, getId, getMetadataTransformerId, getOptions, getOrganization, getParameter, getReceiveTimeout, getResourceReader, getSecurityAttributes, getSupportedSchemes, getSystemSubject, getTitle, getVersion, handleClientException, handleWebApplicationException, init, initSubscribeClientFactory, isAvailable, isAvailable, loadContentTypes, lookupMetadataTransformer, maskId, query, refresh, retrieveResource, setAvailabilityTask, setConfigurationPid, setConnectionTimeout, setContext, setCoordinateOrder, setCsw201, setCswTransformConverter, setCswUrl, setDisableCnCheck, setEventServiceAddress, setFilterAdapter, setFilterBuilder, setFilterDelegate, setForceSpatialFilter, setId, setIsCqlForced, setMetacardMappings, setMetacardTypes, setOutputSchema, setPassword, setPollInterval, setQueryTypeName, setQueryTypeNamespace, setReceiveTimeout, setRegisterForEvents, setResourceReader, setSecurityManager, setupAvailabilityPoll, setUsePosList, setUsername, transform

Methods inherited from class ddf.catalog.util.impl.DescribableImpl

setDescription, setOrganization, setShortname, setTitle, setVersion

Methods inherited from class java.lang.Object

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

Methods inherited from interface ddf.catalog.source.Source

getContentTypes, getSecurityAttributes, isAvailable, isAvailable

Methods inherited from interface ddf.catalog.resource.ResourceReader

getOptions, getSupportedSchemes, retrieveResource

Methods inherited from interface ddf.catalog.util.Describable

getDescription, getId, getOrganization, getTitle, getVersion

Methods inherited from interface ddf.catalog.service.ConfiguredService

getConfigurationPid, setConfigurationPid

Field Detail

PUSH_ALLOWED_PROPERTY

public static final String PUSH_ALLOWED_PROPERTY

See Also:

Constant Field Values

PULL_ALLOWED_PROPERTY

public static final String PULL_ALLOWED_PROPERTY

See Also:

Constant Field Values

AUTO_PUSH

public static final String AUTO_PUSH

See Also:

Constant Field Values

REGISTRY_URL

public static final String REGISTRY_URL

See Also:

Constant Field Values

ID

public static final String ID

See Also:

Constant Field Values

Constructor Detail

RegistryStoreImpl

public RegistryStoreImpl(org.osgi.framework.BundleContext context,
                         CswSourceConfiguration cswSourceConfiguration,
                         com.thoughtworks.xstream.converters.Converter provider,
                         SecureCxfClientFactory factory,
                         EncryptionService encryptionService)

RegistryStoreImpl

public RegistryStoreImpl(EncryptionService encryptionService)

Method Detail

getAdditionalConsumers

protected Map<String,Consumer<Object>> getAdditionalConsumers()

Specified by:

getAdditionalConsumers in class AbstractCswSource

isPushAllowed

public boolean isPushAllowed()

Description copied from interface: RegistryStore

Indicates if write operations are allowed on this registry

Specified by:

isPushAllowed in interface RegistryStore

Returns:

true if allowed otherwise false

isPullAllowed

public boolean isPullAllowed()

Description copied from interface: RegistryStore

Indicates if read operations are allowed on this registry

Specified by:

isPullAllowed in interface RegistryStore

Returns:

true if allowed otherwise false

isAutoPush

public boolean isAutoPush()

Description copied from interface: RegistryStore

Indicates if the identity node should be automatically pushed to another registry store

Specified by:

isAutoPush in interface RegistryStore

Returns:

true if enabled otherwise false

create

public CreateResponse create(CreateRequest request)
                      throws IngestException

Description copied from interface: CatalogStore

Publishes a list of Metacard objects into the catalog.

Specified by:

create in interface CatalogStore

Overrides:

create in class AbstractCswStore

Parameters:

request - - the CreateRequest that includes a List of Metacard objects to be stored in a Source. The ID of the Metacard object will be ignored and populated / generated by the CatalogStore when the record has been stored.

Returns:

the CreateResponse containing a List of fully populated metacards. This should be similar to the parameter list of Metacard objects but it must have the ddf.catalog.data.Metacard ID populated.

Throws:

IngestException - if any problem occurs when storing the metacards

setRegistryUrl

public void setRegistryUrl(String registryUrl)

update

public UpdateResponse update(UpdateRequest request)
                      throws IngestException

Description copied from interface: CatalogStore

Updates a list of Metacard records. Metacard records that are not in the Catalog will not be created.

Specified by:

update in interface CatalogStore

Overrides:

update in class AbstractCswStore

Parameters:

request - - the UpdateRequest that includes updates to Metacard records that have been previously stored in a Source. A given Attribute name-value pair in this request must uniquely identify zero metacards or one metacard in the Source, otherwise an IngestException will be thrown.

Returns:

the UpdateResponse containing a List of Update objects that represent the new (updated) and old (previous) Metacard records.

Throws:

IngestException - if an issue occurs during the update such as multiple records were matched for a single update entry

delete

public DeleteResponse delete(DeleteRequest request)
                      throws IngestException

Description copied from interface: CatalogStore

Deletes records specified by a list of attribute values such as an id attribute.

Specified by:

delete in interface CatalogStore

Overrides:

delete in class AbstractCswStore

Parameters:

request - - the DeleteRequest containing the attribute values associated with Metacards to delete

Returns:

a DeleteResponse with Metacards that were deleted. These Metacards are fully populated in preparation for any processing services.

Throws:

IngestException - if an issue occurs during the delete

query

public SourceResponse query(QueryRequest request)
                     throws UnsupportedQueryException

Specified by:

query in interface Source

Overrides:

query in class AbstractCswSource

Parameters:

request - the query to execute

Returns:

a SourceResponse with query results and query response details

Throws:

UnsupportedQueryException - when the query is not understood, malformed, or not supported by a Source

setAutoPush

public void setAutoPush(boolean autoPush)

setPushAllowed

public void setPushAllowed(boolean pushAllowed)

setPullAllowed

public void setPullAllowed(boolean pullAllowed)

setRegistryId

public void setRegistryId(String registryId)

setMetacardMarshaller

public void setMetacardMarshaller(MetacardMarshaller metacardMarshaller)

getAvailabilityCommand

protected AvailabilityCommand getAvailabilityCommand()

Overrides:

getAvailabilityCommand in class AbstractCswSource

setMetaTypeService

public void setMetaTypeService(org.osgi.service.metatype.MetaTypeService metaTypeService)

setConfigAdmin

public void setConfigAdmin(org.osgi.service.cm.ConfigurationAdmin config)

getRegistryId

public String getRegistryId()

Description copied from interface: RegistryStore

Indicates the Id associated with this registry

Specified by:

getRegistryId in interface RegistryStore

Returns:

registry id in a string