eu.transformproject.provenance.ws

Class ProvenanceWS_MiddlewareTool

java.lang.Object

eu.transformproject.provenance.representation.commonItInstantiation.CommonInstantiation

eu.transformproject.provenance.ws.ProvenanceWS_MiddlewareTool

All Implemented Interfaces:

CommomInstantiationInterface, ProvenanceWS_middleware_Interface

public class ProvenanceWS_MiddlewareTool
extends CommonInstantiation
implements ProvenanceWS_middleware_Interface

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	MIDDLEWARE_GRAPH_PROJECT_NAME_IN_MIDDLEWARE

Fields inherited from class eu.transformproject.provenance.representation.commonItInstantiation.CommonInstantiation

MIDDLEWARE_GRAPH_PROJECT_NAME, server

Constructor Summary

Constructors

Constructor and Description
ProvenanceWS_MiddlewareTool()
ProvenanceWS_MiddlewareTool(java.lang.String localZoneName, java.lang.String fxmlConfig, boolean isResource)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	aggregateResultsForMultiSourceQuery(java.lang.String aggregationQueryA, java.lang.String dataSourceAgentName, java.lang.Object[] dataSourcesA, java.lang.Object aggregatedResults, java.util.Date start) aggregateResultsForMultiSourceQuery, annotates the aggregation result process at the moment it finishes.
java.lang.String[]	analizeMultiSourceQuery(java.lang.String decryptedQueryA, java.lang.String[] subqueries, java.lang.String aggregatedQuery, java.util.Date start) analizeMultiSourceQuery, annotates the process of analyzing multisource queries at the moment the analysis has finished.
void	endsPackageData(java.lang.Object signedDetails, java.lang.Object encryptedPackage) Ends of the packaging process.
java.lang.String	receiveData(java.lang.String receptorQueueName, java.lang.Object encryptedReceivedData) Reception of an encrypted data.
void	sendData(java.lang.String receptorQueueName, java.lang.String encryptedDataA) Send an encrypted data.
java.lang.String	startPackageData(java.lang.String uriDataToPackage, java.util.Date start) Starts of the packaging processing.
java.lang.String	unpackageData(java.lang.String encryptedReceivedDataA, java.lang.String provenanceA, java.lang.Object decryptedDataA, java.util.Date start) Decryptation of an encrypted data.

Methods inherited from class eu.transformproject.provenance.representation.commonItInstantiation.CommonInstantiation

closeSession, createSession, finalize, getSyncDateTime, login, logout

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.transformproject.provenance.representation.commonItInstantiation.CommomInstantiationInterface

closeSession, createSession, getSyncDateTime, login, logout

Field Detail

MIDDLEWARE_GRAPH_PROJECT_NAME_IN_MIDDLEWARE

public static java.lang.String MIDDLEWARE_GRAPH_PROJECT_NAME_IN_MIDDLEWARE

Constructor Detail

ProvenanceWS_MiddlewareTool

public ProvenanceWS_MiddlewareTool(java.lang.String localZoneName,
                           java.lang.String fxmlConfig,
                           boolean isResource)
                            throws java.lang.Exception

Throws:

java.lang.Exception

ProvenanceWS_MiddlewareTool

public ProvenanceWS_MiddlewareTool()
                            throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

analizeMultiSourceQuery

public java.lang.String[] analizeMultiSourceQuery(java.lang.String decryptedQueryA,
                                         java.lang.String[] subqueries,
                                         java.lang.String aggregatedQuery,
                                         java.util.Date start)
                                           throws java.lang.Exception

Description copied from interface: ProvenanceWS_middleware_Interface

analizeMultiSourceQuery, annotates the process of analyzing multisource queries at the moment the analysis has finished.

Specified by:

analizeMultiSourceQuery in interface ProvenanceWS_middleware_Interface

start - date time when the analysis begins

Returns:

a list of the uri of the generated artifacts: one for each subquery and one for the aggregated query.

Throws:

java.lang.Exception

aggregateResultsForMultiSourceQuery

public java.lang.String aggregateResultsForMultiSourceQuery(java.lang.String aggregationQueryA,
                                                   java.lang.String dataSourceAgentName,
                                                   java.lang.Object[] dataSourcesA,
                                                   java.lang.Object aggregatedResults,
                                                   java.util.Date start)
                                                     throws java.lang.Exception

Description copied from interface: ProvenanceWS_middleware_Interface

aggregateResultsForMultiSourceQuery, annotates the aggregation result process at the moment it finishes.

Specified by:

aggregateResultsForMultiSourceQuery in interface ProvenanceWS_middleware_Interface

Returns:

the uri of the artifact representing the aggregated results object

Throws:

java.lang.Exception

startPackageData

public java.lang.String startPackageData(java.lang.String uriDataToPackage,
                                java.util.Date start)
                                  throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Starts of the packaging processing. Annotates the start of the packaging, and returns an artifact identifier that needs to be added in the package to encrypt and/or transmit.

Specified by:

startPackageData in interface CommomInstantiationInterface

Overrides:

startPackageData in class CommonInstantiation

Parameters:

uriDataToPackage - the uri of the artifact associated to the object to be transmitted. This value needs to be obtained through any of the provenance server method.

start - the time in which the packaging process started.

Returns:

encryptedDataA artifact identifier to which the encrypted data will be associated.

Throws:

java.lang.Exception

endsPackageData

public void endsPackageData(java.lang.Object signedDetails,
                   java.lang.Object encryptedPackage)
                     throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Ends of the packaging process. Annotates the packaging of a data at the time the packaging has finished.

Specified by:

endsPackageData in interface CommomInstantiationInterface

Overrides:

endsPackageData in class CommonInstantiation

Parameters:

signedDetails - sign object created during encryptation.

encryptedPackage - the encrypted object.

Throws:

java.lang.Exception

sendData

public void sendData(java.lang.String receptorQueueName,
            java.lang.String encryptedDataA)
              throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Send an encrypted data. Annotates the sending encrypted process data at the time it was sent.

Specified by:

sendData in interface CommomInstantiationInterface

Overrides:

sendData in class CommonInstantiation

Parameters:

receptorQueueName - an string that identifies the queue that controls the sent data messages (e.g. "QW2MW", "MW2DC", etc.).

encryptedDataA - identifier of the encryptedData artifact, as returned by the packageData method.

Throws:

java.lang.Exception

receiveData

public java.lang.String receiveData(java.lang.String receptorQueueName,
                           java.lang.Object encryptedReceivedData)
                             throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Reception of an encrypted data. Annotates an encrypted data reception process at the time it was received.

Specified by:

receiveData in interface CommomInstantiationInterface

Overrides:

receiveData in class CommonInstantiation

Parameters:

receptorQueueName - an string that identifies the queue that controls the reception of data messages (e.g. "QW2MW", "MW2DC", etc.).

encryptedReceivedData - an object describing the data recovered from the queue.

Returns:

encryptedReceivedDataA identifier of the generated encrypted received data artifact.

Throws:

java.lang.Exception

unpackageData

public java.lang.String unpackageData(java.lang.String encryptedReceivedDataA,
                             java.lang.String provenanceA,
                             java.lang.Object decryptedDataA,
                             java.util.Date start)
                               throws java.lang.Exception

Description copied from interface: CommomInstantiationInterface

Decryptation of an encrypted data. Annotates a decryptation data process at the time it finished.

Specified by:

unpackageData in interface CommomInstantiationInterface

Overrides:

unpackageData in class CommonInstantiation

Parameters:

encryptedReceivedDataA - identifier of the generated encrypted received data artifact, as returned by receiveData or packageData methods

provenanceA - identifier of the provenance artifact from which the encrypted received data comes from. This data needs to be extracted from the transmitted package, and should contain the artifact identifier of the transmitted data.

decryptedDataA - an object describing the data decrypted data.

start - the time when the unpackage process starts.

Returns:

decryptedDataA identifier of the generated decrypted data artifact.

Throws:

java.lang.Exception