All Implemented Interfaces:
ddf.catalog.resource.ResourceReader, ddf.catalog.service.ConfiguredService, ddf.catalog.source.ConnectedSource, ddf.catalog.source.FederatedSource, ddf.catalog.source.RemoteSource, ddf.catalog.source.Source, ddf.catalog.util.Describable, ddf.catalog.util.Maskable, org.codice.ddf.platform.services.common.Describable

public class WfsSource extends AbstractWfsSource
Provides a Federated and Connected source implementation for OGC WFS servers.
  • Field Details

  • Constructor Details

    • WfsSource

      public WfsSource(org.codice.ddf.cxf.client.ClientBuilderFactory clientBuilderFactory, ddf.security.encryption.EncryptionService encryptionService, ScheduledExecutorService scheduler)
  • Method Details

    • init

      public void init()
      Init is called when the bundle is initially configured.

      The init process creates a RemoteWfs object using the connection parameters from the configuration.

    • destroy

      public void destroy(int code)
    • refresh

      public void refresh(Map<String,Object> configuration)
      Refresh is called if the bundle configuration is updated.

      If any of the connection related properties change, an attempt is made to re-connect.

      Parameters:
      configuration -
    • isAvailable

      public boolean isAvailable()
    • isAvailable

      public boolean isAvailable(ddf.catalog.source.SourceMonitor callback)
    • query

      public ddf.catalog.operation.SourceResponse query(ddf.catalog.operation.QueryRequest request) throws ddf.catalog.source.UnsupportedQueryException
      Throws:
      ddf.catalog.source.UnsupportedQueryException
    • buildGetFeatureRequest

      protected net.opengis.wfs.v_2_0_0.GetFeatureType buildGetFeatureRequest(ddf.catalog.operation.Query query) throws ddf.catalog.source.UnsupportedQueryException
      Throws:
      ddf.catalog.source.UnsupportedQueryException
    • getContentTypes

      public Set<ddf.catalog.data.ContentType> getContentTypes()
    • getId

      public String getId()
      Specified by:
      getId in interface ddf.catalog.util.Describable
      Specified by:
      getId in interface org.codice.ddf.platform.services.common.Describable
      Overrides:
      getId in class DescribableImpl
    • maskId

      public void maskId(String newSourceId)
      Specified by:
      maskId in interface ddf.catalog.util.Maskable
      Overrides:
      maskId in class MaskableImpl
    • getDescription

      public String getDescription()
      Specified by:
      getDescription in interface ddf.catalog.util.Describable
      Specified by:
      getDescription in interface org.codice.ddf.platform.services.common.Describable
      Overrides:
      getDescription in class DescribableImpl
    • getOrganization

      public String getOrganization()
      Specified by:
      getOrganization in interface ddf.catalog.util.Describable
      Specified by:
      getOrganization in interface org.codice.ddf.platform.services.common.Describable
      Overrides:
      getOrganization in class DescribableImpl
    • getTitle

      public String getTitle()
      Specified by:
      getTitle in interface ddf.catalog.util.Describable
      Specified by:
      getTitle in interface org.codice.ddf.platform.services.common.Describable
      Overrides:
      getTitle in class DescribableImpl
    • getVersion

      public String getVersion()
      Specified by:
      getVersion in interface ddf.catalog.util.Describable
      Specified by:
      getVersion in interface org.codice.ddf.platform.services.common.Describable
      Overrides:
      getVersion in class DescribableImpl
    • retrieveResource

      public ddf.catalog.operation.ResourceResponse retrieveResource(URI uri, Map<String,Serializable> arguments)
    • getSupportedSchemes

      public Set<String> getSupportedSchemes()
    • getOptions

      public Set<String> getOptions(ddf.catalog.data.Metacard metacard)
    • getWfsUrl

      public String getWfsUrl()
    • setWfsUrl

      public void setWfsUrl(String wfsUrl)
    • setAuthenticationType

      public void setAuthenticationType(String authenticationType)
    • setUsername

      public void setUsername(String username)
    • setPassword

      public void setPassword(String password)
    • setDisableCnCheck

      public void setDisableCnCheck(Boolean disableCnCheck)
    • setPollInterval

      public void setPollInterval(Integer interval)
    • getPollInterval

      public Integer getPollInterval()
    • setConnectionTimeout

      public void setConnectionTimeout(Integer timeout)
    • getConnectionTimeout

      public Integer getConnectionTimeout()
    • setReceiveTimeout

      public void setReceiveTimeout(Integer timeout)
    • getReceiveTimeout

      public Integer getReceiveTimeout()
    • setSrsName

      public void setSrsName(String srsName)
    • getSrsName

      public String getSrsName()
    • setFilterAdapter

      public void setFilterAdapter(ddf.catalog.filter.FilterAdapter filterAdapter)
    • setFilterDelgates

      public void setFilterDelgates(Map<QName,WfsFilterDelegate> delegates)
    • setContext

      public void setContext(org.osgi.framework.BundleContext context)
    • setNonQueryableProperties

      public void setNonQueryableProperties(String[] newNonQueryableProperties)
    • getForceSpatialFilter

      public String getForceSpatialFilter()
    • setForceSpatialFilter

      public void setForceSpatialFilter(String forceSpatialFilter)
    • setFeatureConverterFactoryList

      public void setFeatureConverterFactoryList(List<org.codice.ddf.spatial.ogc.wfs.v2_0_0.catalog.converter.FeatureConverterFactory> factories)
    • getMetacardToFeatureMapper

      public List<org.codice.ddf.spatial.ogc.wfs.catalog.mapper.MetacardMapper> getMetacardToFeatureMapper()
    • setMetacardToFeatureMapper

      public void setMetacardToFeatureMapper(List<org.codice.ddf.spatial.ogc.wfs.catalog.mapper.MetacardMapper> mappers)
    • setCoordinateOrder

      public void setCoordinateOrder(String coordinateOrder)
    • setDisableSorting

      public void setDisableSorting(boolean disableSorting)
    • getConfigurationPid

      public String getConfigurationPid()
    • setConfigurationPid

      public void setConfigurationPid(String configurationPid)
    • getFeatureCollectionReader

      public FeatureCollectionMessageBodyReaderWfs20 getFeatureCollectionReader()
    • setFeatureCollectionReader

      public void setFeatureCollectionReader(FeatureCollectionMessageBodyReaderWfs20 featureCollectionMessageBodyReaderWfs20)
    • setForcedFeatureType

      public void setForcedFeatureType(String featureType)