fiftyone.pipeline.cloudrequestengine.flowelements

Class CloudRequestEngineDefault

java.lang.Object

fiftyone.pipeline.core.flowelements.FlowElementBase<TData,TProperty>

fiftyone.pipeline.engines.flowelements.AspectEngineBase<CloudRequestData,AspectPropertyMetaData>

fiftyone.pipeline.cloudrequestengine.flowelements.CloudRequestEngineDefault

All Implemented Interfaces:

CloudRequestEngine, fiftyone.pipeline.core.flowelements.FlowElement<CloudRequestData,AspectPropertyMetaData>, AspectEngine<CloudRequestData,AspectPropertyMetaData>, AutoCloseable

public class CloudRequestEngineDefault
extends AspectEngineBase<CloudRequestData,AspectPropertyMetaData>
implements CloudRequestEngine

Engine that makes requests to the 51Degrees cloud service based on the details passed at creation and the evidence in the FlowData instance. The unprocessed JSON response is stored in the FlowData for other engines to make use of.

Nested Class Summary

Nested classes/interfaces inherited from class fiftyone.pipeline.core.flowelements.FlowElementBase

fiftyone.pipeline.core.flowelements.FlowElementBase.DataFactoryInternal<T extends fiftyone.pipeline.core.data.ElementData>, fiftyone.pipeline.core.flowelements.FlowElementBase.DataFactorySimple<T extends fiftyone.pipeline.core.data.ElementData>

Nested classes/interfaces inherited from interface fiftyone.pipeline.core.flowelements.FlowElement

fiftyone.pipeline.core.flowelements.FlowElement.DataFactory<T extends fiftyone.pipeline.core.data.ElementData>

Field Summary

Fields inherited from class fiftyone.pipeline.engines.flowelements.AspectEngineBase

cache, missingPropertyService

Fields inherited from class fiftyone.pipeline.core.flowelements.FlowElementBase

logger, typedKey

Constructor Summary

Constructors

Constructor and Description
CloudRequestEngineDefault(org.slf4j.Logger logger, fiftyone.pipeline.core.data.factories.ElementDataFactory<CloudRequestData> aspectDataFactory, HttpClient httpClient, String endPoint, String resourceKey, String propertiesEndpoint, String evidenceKeysEndpoint, int timeoutMillis)
CloudRequestEngineDefault(org.slf4j.Logger logger, fiftyone.pipeline.core.data.factories.ElementDataFactory<CloudRequestData> aspectDataFactory, HttpClient httpClient, String endPoint, String resourceKey, String licenseKey, String propertiesEndpoint, String evidenceKeysEndpoint, int timeoutMillis)

Method Summary

Modifier and Type	Method and Description
String	getDataSourceTier()
String	getElementDataKey()
fiftyone.pipeline.core.data.EvidenceKeyFilter	getEvidenceKeyFilter()
List<AspectPropertyMetaData>	getProperties()
Map<String,fiftyone.pipeline.core.data.AccessiblePropertyMetaData.ProductMetaData>	getPublicProperties() A collection of the properties that the cloud service can populate in the JSON response.
protected void	processEngine(fiftyone.pipeline.core.data.FlowData data, CloudRequestData aspectData)
protected void	unmanagedResourcesCleanup()

Methods inherited from class fiftyone.pipeline.engines.flowelements.AspectEngineBase

getExecutor, getLazyLoadingConfiguration, getTypedDataKey, managedResourcesCleanup, processInternal, setCache, setLazyLoading

Methods inherited from class fiftyone.pipeline.core.flowelements.FlowElementBase

addPipeline, close, close, finalize, getDataFactory, getPipelines, getProperty, isClosed, isConcurrent, process

Methods inherited from class java.lang.Object

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

Methods inherited from interface fiftyone.pipeline.engines.flowelements.AspectEngine

getExecutor, getLazyLoadingConfiguration, setCache, setLazyLoading

Methods inherited from interface fiftyone.pipeline.core.flowelements.FlowElement

addPipeline, getDataFactory, getProperty, getTypedDataKey, isClosed, isConcurrent, process

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

CloudRequestEngineDefault

public CloudRequestEngineDefault(org.slf4j.Logger logger,
                                 fiftyone.pipeline.core.data.factories.ElementDataFactory<CloudRequestData> aspectDataFactory,
                                 HttpClient httpClient,
                                 String endPoint,
                                 String resourceKey,
                                 String propertiesEndpoint,
                                 String evidenceKeysEndpoint,
                                 int timeoutMillis)

CloudRequestEngineDefault

public CloudRequestEngineDefault(org.slf4j.Logger logger,
                                 fiftyone.pipeline.core.data.factories.ElementDataFactory<CloudRequestData> aspectDataFactory,
                                 HttpClient httpClient,
                                 String endPoint,
                                 String resourceKey,
                                 String licenseKey,
                                 String propertiesEndpoint,
                                 String evidenceKeysEndpoint,
                                 int timeoutMillis)

Method Detail

getProperties

public List<AspectPropertyMetaData> getProperties()

Specified by:

getProperties in interface fiftyone.pipeline.core.flowelements.FlowElement<CloudRequestData,AspectPropertyMetaData>

Specified by:

getProperties in class AspectEngineBase<CloudRequestData,AspectPropertyMetaData>

getDataSourceTier

public String getDataSourceTier()

Specified by:

getDataSourceTier in interface AspectEngine<CloudRequestData,AspectPropertyMetaData>

Specified by:

getDataSourceTier in class AspectEngineBase<CloudRequestData,AspectPropertyMetaData>

getElementDataKey

public String getElementDataKey()

Specified by:

getElementDataKey in interface fiftyone.pipeline.core.flowelements.FlowElement<CloudRequestData,AspectPropertyMetaData>

Specified by:

getElementDataKey in class fiftyone.pipeline.core.flowelements.FlowElementBase<CloudRequestData,AspectPropertyMetaData>

getEvidenceKeyFilter

public fiftyone.pipeline.core.data.EvidenceKeyFilter getEvidenceKeyFilter()

Specified by:

getEvidenceKeyFilter in interface fiftyone.pipeline.core.flowelements.FlowElement<CloudRequestData,AspectPropertyMetaData>

Specified by:

getEvidenceKeyFilter in class fiftyone.pipeline.core.flowelements.FlowElementBase<CloudRequestData,AspectPropertyMetaData>

getPublicProperties

public Map<String,fiftyone.pipeline.core.data.AccessiblePropertyMetaData.ProductMetaData> getPublicProperties()

Description copied from interface: CloudRequestEngine

A collection of the properties that the cloud service can populate in the JSON response. Keyed on property name.

Specified by:

getPublicProperties in interface CloudRequestEngine

Returns:

public properties

processEngine

protected void processEngine(fiftyone.pipeline.core.data.FlowData data,
                             CloudRequestData aspectData)
                      throws IOException

Specified by:

processEngine in class AspectEngineBase<CloudRequestData,AspectPropertyMetaData>

Throws:

IOException

unmanagedResourcesCleanup

protected void unmanagedResourcesCleanup()

Specified by:

unmanagedResourcesCleanup in class fiftyone.pipeline.core.flowelements.FlowElementBase<CloudRequestData,AspectPropertyMetaData>