http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/PublisherFactory.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/PublisherFactory.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/PublisherFactory.java deleted file mode 100644 index 63c9063..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/PublisherFactory.java +++ /dev/null @@ -1,54 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking; - -import java.lang.reflect.Constructor; - -import org.apache.airavata.workflow.tracking.common.ConstructorProps; -import org.apache.airavata.workflow.tracking.common.NotifierCreationException; -import org.apache.airavata.workflow.tracking.common.WorkflowTrackingContext; -import org.apache.airavata.workflow.tracking.impl.publish.NotificationPublisher; - -public class PublisherFactory { - protected static final Class[] PUBLISHER_CONSTRUCTOR_PARAM_TYPES = { ConstructorProps.class }; - - protected static NotificationPublisher createSomePublisher(String publisherClassName, - WorkflowTrackingContext context) { - - try { - // Try to load the notifier's class. - Class publisherClazz = Class.forName(publisherClassName); - - // Try to get the notifier's constructor. - Constructor publisherConstructor = publisherClazz.getConstructor(PUBLISHER_CONSTRUCTOR_PARAM_TYPES); - - // Define the parameters for the notifier's constructor. - Object[] constructorParameters = { context }; - - // Create the notifier by calling its constructor. - return (NotificationPublisher) publisherConstructor.newInstance(constructorParameters); - - } catch (Exception exception) { - throw new NotifierCreationException(exception); - } - } -}
http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/ResourceNotifier.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/ResourceNotifier.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/ResourceNotifier.java deleted file mode 100644 index b97feaf..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/ResourceNotifier.java +++ /dev/null @@ -1,61 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking; - -import org.apache.airavata.workflow.tracking.common.WorkflowTrackingContext; - -/** - * Utility to create and send notifications related to resource broker and job status.r - */ -public interface ResourceNotifier { - - /** - * Method resourceMapping - * - * @param entity - * an InvocationEntity - * @param mappedResource - * a String - * @param retryStatusCount - * an int - * @param descriptionAndAnnotationa - * String - * - */ - void resourceMapping(WorkflowTrackingContext context, String mappedResource, int retryStatusCount, - String... descriptionAndAnnotation); - - /** - * Method jobStatus - * - * @param entity - * an InvocationEntity - * @param status - * a String - * @param retryCount - * an int - * @param descriptionAndAnnotationa - * String - * - */ - void jobStatus(WorkflowTrackingContext context, String status, int retryCount, String... descriptionAndAnnotation); -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/ServiceNotifier.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/ServiceNotifier.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/ServiceNotifier.java deleted file mode 100644 index 79bb0f8..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/ServiceNotifier.java +++ /dev/null @@ -1,235 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking; - -import java.net.URI; - -import org.apache.airavata.workflow.tracking.common.InvocationContext; -import org.apache.airavata.workflow.tracking.common.InvocationEntity; -import org.apache.airavata.workflow.tracking.common.WorkflowTrackingContext; -import org.apache.xmlbeans.XmlObject; - -/** - * Utility to create and send Lead provenance related notification messages. this tracks files used, produced, and - * transfered by this application, application begin and end. - * - * <pre> - * appStarted(A1) - * fileConsumed(F1) - * fileProduced(F2) - * appFinishedSuccess(A1, F2) | appFinishedFailed(A1, ERR) - * flush() - * </pre> - */ - -public interface ServiceNotifier extends GenericNotifier { - - /** - * send a message indicating the service has been instantiated and will accept messages henceforth. - * - * @param serviceID - * an URI that identifies the service instance - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void serviceInitialized(WorkflowTrackingContext context, URI serviceID, String... descriptionAndAnnotation); - - /** - * send a message indicating the service instance has terminated and will not accept or generate any future - * messages. - * - * @param serviceID - * an URI that identifies the service instance - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void serviceTerminated(WorkflowTrackingContext context, URI serviceID, String... descriptionAndAnnotation); - - /** - * Method serviceInvoked. This service instance has received a message from the initiator to start executing. - * - * @param receiver - * identity of this service invocation - * @param initiator - * identity of entity that invoked this service - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - * @return an InvocationContext that encapsulates this invocation. This object should be passed to any notification - * that is generated as part of this invocation. - * - */ - public InvocationContext serviceInvoked(WorkflowTrackingContext context, InvocationEntity receiver, - String... descriptionAndAnnotation); - - /** - * Method serviceInvoked. This service instance has received a message from the initiator to start executing. - * - * @param receiver - * identity of this service invocation - * @param initiator - * identity of entity that invoked this service - * @param header - * the context for this invocation (soap:header) - * @param body - * the message received that has the actions and inputs (soap:body) - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - * @return an InvocationContext that encapsulates this invocation. This object should be passed to any notification - * that is generated as part of this invocation. - * - */ - public InvocationContext serviceInvoked(WorkflowTrackingContext wtcontext, InvocationEntity initiator, - XmlObject header, XmlObject body, String... descriptionAndAnnotation); - - /** - * Method sendingResult. Return the result of the invocation back to the initiator of the invocation. This happens - * when a request-response pattern is followed. - * - * @param context - * the context for this invocation as returned by serviceInvoked - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void sendingResult(WorkflowTrackingContext wtcontext, InvocationContext context, - String... descriptionAndAnnotation); - - /** - * Method sendingResult. Return the result of the invocation back to the initiator of the invocation. This happens - * when a request-response pattern is followed. - * - * @param context - * the context for this invocation as returned by serviceInvoked - * @param header - * the context for the response to the invocation (soap:header) - * @param body - * the message that is sent as output of the invocation (soap:body) - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void sendingResult(WorkflowTrackingContext wtcontext, InvocationContext context, XmlObject header, - XmlObject body, String... descriptionAndAnnotation); - - /** - * Method sendingFault. Return a fault as the response to the invocation, sent back to the initiator of the - * invocation. This happens when a request-response pattern is followed. - * - * @param context - * the context for this invocation as returned by serviceInvoked - * @param error - * human readable description of the failure to be sent with the message - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - * - */ - public void sendingFault(WorkflowTrackingContext wtcontext, InvocationContext context, - String... descriptionAndAnnotation); - - /** - * Method sendingFault. Return a fault as the response to the invocation, sent back to the initiator of the - * invocation. This happens when a request-response pattern is followed. - * - * @param context - * the context for this invocation as returned by serviceInvoked - * @param header - * the context for the response to the invocation (soap:header) - * @param fault - * the fault that is sent as output of the invocation (soap:fault) - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void sendingFault(WorkflowTrackingContext wtcontext, InvocationContext context, XmlObject header, - XmlObject faultBody, String... descriptionAndAnnotation); - - /** - * send sendingResponseSucceeded message. Acknowledges that the response to this invocation was successfully sent to - * the initator of the invocation. - * - * @param context - * the context for this invocation as returned by serviceInvoked - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void sendingResponseSucceeded(WorkflowTrackingContext wtcontext, InvocationContext context, - String... descriptionAndAnnotation); - - /** - * send sendingResponseSucceeded message. Acknowledges that the response to this invocation could not be sent to the - * initator of the invocation. Can be a local failure or a remote failure. - * - * @param context - * the context for this invocation as returned by serviceInvoked - * @param error - * human readable description of the failure to be sent with the message - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void sendingResponseFailed(WorkflowTrackingContext wtcontext, InvocationContext context, - String... descriptionAndAnnotation); - - /** - * send sendingResponseSucceeded message. Acknowledges that the response to this invocation could not be sent to the - * initator of the invocation. Can be a local failure or a remote failure. - * - * @param context - * the context for this invocation as returned by serviceInvoked - * @param trace - * a throwable that has the trace for the error - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void sendingResponseFailed(WorkflowTrackingContext wtcontext, InvocationContext context, Throwable trace, - String... descriptionAndAnnotation); - -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/WorkflowNotifier.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/WorkflowNotifier.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/WorkflowNotifier.java deleted file mode 100644 index 1ee4cbd..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/WorkflowNotifier.java +++ /dev/null @@ -1,331 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking; - -import java.net.URI; - -import org.apache.airavata.workflow.tracking.common.InvocationContext; -import org.apache.airavata.workflow.tracking.common.InvocationEntity; -import org.apache.airavata.workflow.tracking.common.WorkflowTrackingContext; -import org.apache.xmlbeans.XmlObject; - -/** - * Utility to create and send Lead notification messages from a Workflow Engine - * - * A typical sequence of usage of this interface would be as follows: - * - * <pre> - * WORKFLOW (Using this:Workflow Notifier):: - * workflowStarted(W1) - * invokeServiceStarted(S1) - * -- invoke service -- - * -- service invokes application -- - * APPLICATION (Using Notifier Interface): - * appStarted(A1) - * info(...) - * fileReceiveStarted(F1) - * -- do gridftp get to stage input files -- - * fileReceiveFinished(F1) - * fileConsumed(F1) - * computationStarted(C1) - * -- call fortran code to process input files -- - * computationFinished(C1) - * fileProduced(F2) - * fileSendStarted(F2) - * -- do gridftp put to save output files -- - * fileSendFinished(F2) - * publishURL(F2) - * appFinishedSuccess(A1, F2) | appFinishedFailed(A1, ERR) - * flush() - * WORKFLOW (Using this:Workflow Notifier): - * -- return from service invocation -- - * invokeServiceFinishedSuccess(S1) | invokeServiceFinishedFailed(S1, ERR) - * invokeServiceStarted(S2) - * -- invoke service -- - * ... - * workflowFinishedSuccess(W1) | workflowFinishedFailer(W1, ERR) - * flush() - * </pre> - * - * @version $Revision: 1.4 $ - * @author - */ -public interface WorkflowNotifier extends ServiceNotifier { - - /** - * send a message indicating the workflow has been instantiated and will accept messages henceforth. - * - * @param context - * current workflow tracking context. - * @param serviceID - * an URI that identifies the workflow instance - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void workflowInitialized(WorkflowTrackingContext context, URI serviceID, String... descriptionAndAnnotation); - - /** - * send a message indicating the workflow instance has terminated and will not accept or generate any future - * messages. - * - * @param context - * current workflow tracking context. - * @param serviceID - * an URI that identifies the workflow instance - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void workflowTerminated(WorkflowTrackingContext context, URI serviceID, String... descriptionAndAnnotation); - - /** - * Method workflowInvoked. This workflow has received a message from the initiator to start executing. - * - * @param context - * current workflow tracking context. - * @param receiver - * identity of this workflow invocation - * @param initiator - * identity of entity that invoked this workflow - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - * @return an InvocationContext that encapsulates this invocation. This object should be passed to any notification - * that is generated as part of this invocation. It can also be used as the InvocationEntity for this - * workflow in future notifications. - * - */ - public InvocationContext workflowInvoked(WorkflowTrackingContext context, InvocationEntity initiator, - String... descriptionAndAnnotation); - - /** - * Method workflowInvoked. This workflow has received a message from the initiator to start executing. - * - * @param context - * current workflow tracking context. - * @param receiver - * identity of this workflow invocation - * @param initiator - * identity of entity that invoked this workflow - * @param header - * the context within which this invocation takes place (soap:header) - * @param body - * the message that causes this invocation (soap:body) - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - * @return an InvocationContext that encapsulates this invocation. This object should be passed to any notification - * that is generated as part of this invocation. - * - */ - public InvocationContext workflowInvoked(WorkflowTrackingContext context, InvocationEntity initiator, - XmlObject header, XmlObject body, String... descriptionAndAnnotation); - - /** - * Method invokingService. This workflow is initiating an invocation upon another service. - * - * @param context - * current workflow tracking context. - * @param initiator - * identity of this workflow invocation - * @param receiver - * identity of entity that this workflow is invoking - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - * @return an InvocationContext that encapsulates this invocation. This object should be passed to any notification - * that is generated as part of this invocation. - * - */ - public InvocationContext invokingService(WorkflowTrackingContext context, InvocationEntity receiver, - String... descriptionAndAnnotation); - - /** - * Method invokingService. This workflow is initiating an invocation upon another service. - * - * @param context - * current workflow tracking context. - * @param initiator - * identity of this workflow invocation - * @param receiver - * identity of entity that this workflow is invoking - * @param header - * the context for this invocation (soap:header) - * @param body - * the message that is sent with the action and input to start the invocation (soap:body) - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - * @return an InvocationContext that encapsulates this invocation. This object should be passed to any notification - * that is generated as part of this invocation. - * - */ - public InvocationContext invokingService(WorkflowTrackingContext context, InvocationEntity receiver, - XmlObject header, XmlObject body, String... descriptionAndAnnotation); - - /** - * Method invokingServiceSucceeded. Acnowledge that the invocation request was received by the remote service - * successfully. - * - * @param context - * current workflow tracking context. - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - * @param context - * the context for this invocation as returned by invokeService - * - */ - public void invokingServiceSucceeded(WorkflowTrackingContext wtcontext, InvocationContext context, - String... descriptionAndAnnotation); - - /** - * Method invokingServiceFailed. Report that the invocation request could not be sent to the remote service. Can be - * a local failure or a remote failure. - * - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - * @param wtcontext - * current workflow tracking context. - * @param context - * the context for this invocation as returned by invokeService - * @param error - * a String describing the error - * - */ - public void invokingServiceFailed(WorkflowTrackingContext wtcontext, InvocationContext context, - String... descriptionAndAnnotation); - - /** - * Method invokingServiceFailed. Report that the invocation request could not be sent to the remote service. Can be - * a local failure or a remote failure. - * - * @param wtcontext - * current workflow tracking context. - * @param context - * the context for this invocation as returned by invokeService - * @param trace - * a throwable that has the trace for the error - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void invokingServiceFailed(WorkflowTrackingContext wtcontext, InvocationContext context, Throwable trace, - String... descriptionAndAnnotation); - - /** - * Method receivedResult. Indicates that the invocation that this workflow initiated has received a response. This - * happens when a request-response pattern is followed. - * - * @param wtcontext - * current workflow tracking context. - * @param context - * the context for this invocation as returned by invokeService - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void receivedResult(WorkflowTrackingContext wtcontext, InvocationContext context, - String... descriptionAndAnnotation); - - /** - * Method receivedResult. Indicates that the invocation that this workflow initiated has received a response. This - * happens when a request-response pattern is followed. - * - * @param wtcontext - * current workflow tracking context. - * @param context - * the context for this invocation as returned by invokeService - * @param header - * the context for the response to the invocation (soap:header) - * @param body - * the message that is received as output of the invocation (soap:body) - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void receivedResult(WorkflowTrackingContext wtcontext, InvocationContext context, XmlObject header, - XmlObject body, String... descriptionAndAnnotation); - - /** - * Method receivedResult. Indicates that the invocation that this workflow initiated has received a fault as - * response. This happens when a request-response pattern is followed. - * - * @param wtcontext - * current workflow tracking context. - * @param context - * the context for this invocation as returned by invokeService - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void receivedFault(WorkflowTrackingContext wtcontext, InvocationContext context, - String... descriptionAndAnnotation); - - /** - * Method receivedResult. Indicates that the invocation that this workflow initiated has received a fault as - * response. This happens when a request-response pattern is followed. - * - * @param wtcontext - * current workflow tracking context. - * @param context - * the context for this invocation as returned by invokeService - * @param header - * the context for the response to the invocation (soap:header) - * @param fault - * the fault that is sent as output of the invocation (soap:fault) - * @param descriptionAndAnnotation - * optional vararg. The first element is used as the human readable description for this notification. - * The subsequent strings need to be serialized XML fragments that are added as annotation to the - * notification. - * - */ - public void receivedFault(WorkflowTrackingContext wtcontext, InvocationContext context, XmlObject header, - XmlObject faultBody, String... descriptionAndAnnotation); - -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/WorkflowTrackingException.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/WorkflowTrackingException.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/WorkflowTrackingException.java deleted file mode 100644 index af8ed51..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/WorkflowTrackingException.java +++ /dev/null @@ -1,46 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking; - -public class WorkflowTrackingException extends RuntimeException { - - public WorkflowTrackingException() { - super(); - // TODO Auto-generated constructor stub - } - - public WorkflowTrackingException(String message) { - super(message); - // TODO Auto-generated constructor stub - } - - public WorkflowTrackingException(String message, Throwable cause) { - super(message, cause); - // TODO Auto-generated constructor stub - } - - public WorkflowTrackingException(Throwable cause) { - super(cause); - // TODO Auto-generated constructor stub - } - -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/Callback.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/Callback.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/Callback.java deleted file mode 100644 index 0a2b248..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/Callback.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.client; - -import org.apache.xmlbeans.XmlObject; - -/** - * Interface to be implemented to receive notifications after starting subscription - * - */ -public interface Callback { - - /** - * Method deliverMessage is called when a Lead Message is received on the subscribed topic. - * - * @param topic - * the topic to which this message was sent. This can also be retrieved from the messageObj XMlObject - * directly after typecasting. - * @param messageObj - * the XmlObject representing one of the LeadMessages, This needs to be typecast to the correct message - * type before being used. - * - */ - public void deliverMessage(String topic, NotificationType notificationType, XmlObject messageObj); - -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/LeadNotificationManager.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/LeadNotificationManager.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/LeadNotificationManager.java deleted file mode 100644 index 1a3422a..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/LeadNotificationManager.java +++ /dev/null @@ -1,188 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.client; - -import java.rmi.RemoteException; - -import javax.xml.namespace.QName; - -import org.apache.airavata.commons.WorkFlowUtils; -import org.apache.airavata.workflow.tracking.impl.subscription.LeadNotificationHandler; -import org.apache.airavata.workflow.tracking.impl.subscription.MessageBoxNotificationHandler; -import org.apache.airavata.wsmg.client.protocol.WSEProtocolClient; -import org.apache.airavata.wsmg.commons.NameSpaceConstants; -import org.apache.axiom.om.OMAbstractFactory; -import org.apache.axiom.om.OMElement; -import org.apache.axis2.addressing.EndpointReference; -import org.apache.axis2.addressing.EndpointReferenceHelper; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class LeadNotificationManager { - - private final static Logger logger = LoggerFactory.getLogger(LeadNotificationManager.class); - - /** - * THis API call could be used if the user created a Subscription in an earlier run and now the service is being - * restarted and the user wants to use the earlier subscription. All the following information is in the - * Subscription object returned in the createSubscription API call. - * - * @param messageBoxUrl - * @param brokerLocation - * @param eprOfMessageBox - * @param SubscriptionID - * @param topic - * @param xpath - * Xpath expression to subscribe to. Can be null. - * @param callback - * @param subscribePermanatly - * Makes the renew a permanant subscription - * @return - * @throws Exception - */ - public static Subscription startListeningToSavedSubscription(String brokerLocation, EndpointReference msgBoxAddrs, - String SubscriptionID, String topic, String xpath, Callback callback, boolean subscribePermanatly) - throws Exception { - - return new MessageBoxNotificationHandler(msgBoxAddrs.getAddress(), brokerLocation) - .startListeningToPreviousMessageBox(msgBoxAddrs, SubscriptionID, topic, xpath, callback, - subscribePermanatly); - } - - /** - * This API call could be used to keep-alive a subscription. It would not start a new listener. - * - * @param messageBoxUrl - * @param brokerLocation - * @param eprOfMessageBox - * @param SubscriptionID - * @param topic - * @param xpath - * Xpath expression to subscribe to. Can be null. - * @param subscribePermanatly - * Makes the renew a permanant subscription - * @return - * @throws Exception - */ - public static Subscription renewMessageboxSubscription(String messageBoxUrl, String brokerLocation, - String eprOfMessageBox, String SubscriptionID, String topic, String xpath, boolean subscribePermanatly) - throws Exception { - - return new MessageBoxNotificationHandler(messageBoxUrl, brokerLocation).renewMessageboxSubscription( - eprOfMessageBox, SubscriptionID, topic, xpath, subscribePermanatly); - } - - public static Subscription renewMessageboxSubscription(String brokerLocation, EndpointReference eprOfMessageBox, - String SubscriptionID, String topic, String xpath, boolean subscribePermanatly) throws Exception { - - return new MessageBoxNotificationHandler(eprOfMessageBox.getAddress(), brokerLocation) - .renewMessageboxSubscription(eprOfMessageBox, SubscriptionID, topic, xpath, subscribePermanatly); - } - - /** - * Create a messagebox subscription and does all the broker subscriptions required. - * - * @param messageBoxUrl - * @param brokerLocation - * @param topic - * @param xpath - * Xpath expression to subscribe to. Can be null. - * @param callback - * @param subscribePermanatly - * Cretes the subscriptions permamntly - * @param userAgent - * This will be displayed in the messagebox subscription can be null - * @return - * @throws RemoteException - */ - public static Subscription createMessageBoxSubscription(String messageBoxUrl, String brokerLocation, String topic, - String xpath, Callback callback, boolean subscribePermanatly) throws Exception { - - return new MessageBoxNotificationHandler(messageBoxUrl, brokerLocation).createMsgBoxSubscription(topic, xpath, - callback, subscribePermanatly); - } - - /** - * Create a messagebox subscription and does all the broker subscriptions required. - * - * @param messageBoxUrl - * @param brokerLocation - * @param topic - * @param xpath - * @param callback - * @param userAgent - * This will be displayed in the messagebox subscription can be null - * @return - * @throws Exception - */ - public static Subscription createMessageBoxSubscription(String messageBoxUrl, String brokerLocation, String topic, - String xpath, Callback callback) throws Exception { - - return new MessageBoxNotificationHandler(messageBoxUrl, brokerLocation).createSubscription(topic, xpath, - callback, false); - } - - /** - * @param brokerLocation - * @param topic - * @param callback - * @return - * @throws Exception - */ - public static Subscription createSubscription(String brokerLocation, String topic, Callback callback, - int consumerServerPort) throws Exception { - LeadNotificationHandler handler = new LeadNotificationHandler(brokerLocation, topic, callback, - consumerServerPort); - - return handler.createSubscription(); - } - - public static String getBrokerPublishEPR(String brokerURL, String topic) { - - brokerURL = WorkFlowUtils.formatURLString(brokerURL); - - EndpointReference encodedEpr = WSEProtocolClient.createEndpointReference(brokerURL, topic); - - String ret = null; - - try { - OMElement eprCrEl = EndpointReferenceHelper.toOM(OMAbstractFactory.getOMFactory(), encodedEpr, new QName( - "EndpointReference"), NameSpaceConstants.WSA_NS.getNamespaceURI()); - - ret = eprCrEl.toStringWithConsume(); - - } catch (Exception e) { - logger.error("unable to convert broker url", e); - } - - return ret; - - /* - * String epr = null; brokerURL = WorkFlowUtils.formatURLString(brokerURL); if (brokerURL.endsWith("/")) { epr = - * brokerURL + STRING_TOPIC + topic; } else { epr = brokerURL + "/" + STRING_TOPIC + topic; } - * - * epr = "<wsa:EndpointReference " + "xmlns:wsa='http://www.w3.org/2005/08/addressing'>" + "<wsa:Address>" + epr - * + "</wsa:Address>" + "</wsa:EndpointReference>"; return epr; - */ - - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/NotificationType.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/NotificationType.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/NotificationType.java deleted file mode 100644 index 1ee6fba..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/NotificationType.java +++ /dev/null @@ -1,41 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.client; - -public enum NotificationType { - - ServiceInitialized, WorkflowInitialized, ServiceTerminated, WorkflowTerminated, WorkflowPaused, WorkflowResumed, - - InvokingService, WorkflowInvoked, ServiceInvoked, InvokingServiceSucceeded, InvokingServiceFailed, - - SendingResult, SendingFault, ReceivedResult, ReceivedFault, SendingResponseSucceeded, SendingResponseFailed, - - DataConsumed, DataProduced, - - ApplicationAudit, ComputationDuration, DataSendDuration, DataReceiveDuration, - - PublishURL, LogInfo, LogException, LogWarning, LogDebug, - - ResourceMapping, JobStatus, - - Unknown -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/Subscription.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/Subscription.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/Subscription.java deleted file mode 100644 index cab6f12..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/client/Subscription.java +++ /dev/null @@ -1,135 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.client; - -import java.rmi.RemoteException; - -import org.apache.airavata.workflow.tracking.impl.subscription.MessageBoxNotificationHandler; -import org.apache.airavata.wsmg.client.ConsumerServer; -import org.apache.airavata.wsmg.client.MsgBrokerClientException; -import org.apache.airavata.wsmg.client.WseMsgBrokerClient; -import org.apache.axis2.addressing.EndpointReference; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class Subscription { - - private static final Logger logger = LoggerFactory.getLogger(Subscription.class); - - private String subscriptionID; - - private String topic; - - private Callback callback; - - private ConsumerServer xs; - - private MessageBoxNotificationHandler messageBoxNotificationHandler; - - private EndpointReference messageBoxEPR; - - private String brokerURL; - - public Subscription(MessageBoxNotificationHandler messageBoxNotificationHandler, String subscriptionID, - String topic, Callback callback, String brokerURL) { - this.messageBoxNotificationHandler = messageBoxNotificationHandler; - this.subscriptionID = subscriptionID; - this.topic = topic; - this.callback = callback; - this.brokerURL = brokerURL; - } - - public Subscription(ConsumerServer xs, String subscriptionID, String topic, Callback callback, String brokerURL) { - super(); - this.xs = xs; - this.subscriptionID = subscriptionID; - this.topic = topic; - this.callback = callback; - this.brokerURL = brokerURL; - } - - public Callback getCallback() { - return callback; - } - - public String getTopic() { - return topic; - } - - public void destroy() throws RemoteException { - if (this.xs != null) { - xs.stop(); - WseMsgBrokerClient client = new WseMsgBrokerClient(); - client.init(this.brokerURL); - try { - client.unSubscribe(this.subscriptionID); - } catch (MsgBrokerClientException e) { - logger.error("axisFault occured on unsubscribing subscription ID :" + this.subscriptionID, e); - } - } else if (this.messageBoxNotificationHandler != null) { - this.messageBoxNotificationHandler.destroy(messageBoxEPR); - } - } - - public EndpointReference getMessageBoxEPR() { - return messageBoxEPR; - } - - public void setMessageBoxEpr(EndpointReference messageBoxEPR) { - this.messageBoxEPR = messageBoxEPR; - } - - public String getSubscriptionID() { - return subscriptionID; - } - - public void setSubscriptionID(String subscriptionID) { - this.subscriptionID = subscriptionID; - } - - public String getBrokerURL() { - return brokerURL; - } - - public void setBrokerURL(String brokerURL) { - this.brokerURL = brokerURL; - } - - public String getBrokerPublishEPR() { - return LeadNotificationManager.getBrokerPublishEPR(this.brokerURL, this.topic); - } - - public String getConsumerEPR() { - - String ret = null; - - if (null != xs) { - - String[] eprs = xs.getConsumerServiceEPRs(); - if (eprs.length > 0) - ret = eprs[0]; - - } - return ret; - } - -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/AnnotationConsts.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/AnnotationConsts.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/AnnotationConsts.java deleted file mode 100644 index 9789f3a..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/AnnotationConsts.java +++ /dev/null @@ -1,82 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -import java.util.ArrayList; -import java.util.EnumSet; -import java.util.List; - -import javax.xml.namespace.QName; - -public enum AnnotationConsts { - - // localName, simpleType, multiValued - ExperimentID("experimentID", true, false), // experiment id used in mylead - ServiceLocation("ServiceLocation", true, false), // location (EPR?) of the service - AbstractServiceID("abstractServiceID", true, false), // abstract service QName - AbstractWorkflowID("abstractWorkflowID", true, false), // abstract workfow QName - DataProductType("dataProductType", true, false), // namelist file, etc. - TypedSOAPRequest("typedSOAPRequest", false, false), // SOAP request with leadType fields set - TypedSOAPResponse("typedSOAPResponse", false, false), // SOAP request with leadType fields set - UserDN("userDN", true, false), // User DN of person invoking the service - ParamNameInSOAP("paramName", true, false), // element name of the (data) parameter in the SOAP Message - ServiceReplicaID("Service_Replica_ID", true, false); - - public QName getQName() { - return qname; - } - - public boolean isSimpleType() { - return isSimpleType; - } - - public boolean isMultiValued() { - return isMultiValued; - } - - private static final String WFT_NS = "http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking";; - private QName qname; - private boolean isSimpleType, isMultiValued; - - private AnnotationConsts(String name, boolean isSimpleType_, boolean isMultiValued_) { - this(WFT_NS, name, isSimpleType_, isMultiValued_); - } - - private AnnotationConsts(String ns, String name, boolean isSimpleType_, boolean isMultiValued_) { - qname = new QName(ns, name); - isSimpleType = isSimpleType_; - isMultiValued = isMultiValued_; - } - - private static List<QName> qNameList = null; - - public static List<QName> getQNameList() { - if (qNameList != null) - return new ArrayList<QName>(qNameList); - final EnumSet<AnnotationConsts> allAnnos = EnumSet.allOf(AnnotationConsts.class); - List<QName> qNameList = new ArrayList<QName>(); - for (AnnotationConsts anno : allAnnos) { - qNameList.add(anno.getQName()); - } - return qNameList; - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/AnnotationProps.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/AnnotationProps.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/AnnotationProps.java deleted file mode 100644 index b0579bf..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/AnnotationProps.java +++ /dev/null @@ -1,310 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; -import java.util.Set; - -import javax.xml.namespace.QName; - -import org.apache.xmlbeans.XmlObject; - -/** - * Use set(list) or setXml(list) to set multi valued annotations. Use add() or addXml() to add to multi valued - * annotations. Use set(string) or setXml(xmlobj) to set single valued annotations. - * - */ -public class AnnotationProps { - - private Map<AnnotationConsts, Object> localMap; - - private AnnotationProps() { - localMap = new HashMap<AnnotationConsts, Object>(); - } - - public static AnnotationProps newProps() { - return new AnnotationProps(); - } - - public static AnnotationProps newProps(AnnotationConsts key, String value) { - return newProps().set(key, value); - } - - public static AnnotationProps newProps(AnnotationConsts key, XmlObject value) { - return newProps().setXml(key, value); - } - - /** - * Use for single valued string annotation - * - * @param key - * an AnnotationConsts - * @param value - * a String - * - * @return an AnnotationProps - * - */ - public AnnotationProps set(AnnotationConsts key, String value) { - if (!key.isSimpleType()) - throw new RuntimeException("Expect XML Object value for annotation, not String [" + key + ", " + value - + "]"); - if (key.isMultiValued()) - throw new RuntimeException("Expect list XML Object value for annotation, not single [" + key + ", " + value - + "]"); - - localMap.put(key, value); - return this; - } - - /** - * Use for single valued XmlObj annotation - * - * @param key - * an AnnotationConsts - * @param value - * a XmlObject - * - * @return an AnnotationProps - * - */ - public AnnotationProps setXml(AnnotationConsts key, XmlObject value) { - if (key.isSimpleType()) - throw new RuntimeException("Expect string value for annotation, not Xml Object [" + key + ", " + value - + "]"); - if (key.isMultiValued()) - throw new RuntimeException("Expect list XML Object value for annotation, not single [" + key + ", " + value - + "]"); - - localMap.put(key, value); - return this; - } - - /** - * Use for multivalued string annotation - * - * @param key - * an AnnotationConsts - * @param value - * a List - * - * @return an AnnotationProps - * - */ - public AnnotationProps set(AnnotationConsts key, List<String> value) { - if (!key.isSimpleType()) - throw new RuntimeException("Expect XML Object value for annotation, not String [" + key + ", " + value - + "]"); - if (!key.isMultiValued()) - throw new RuntimeException("Expect single XML Object value for annotation, not List [" + key + ", " + value - + "]"); - - localMap.put(key, value); - return this; - } - - /** - * Use for multivalued XmlObj annotation - * - * @param key - * an AnnotationConsts - * @param value - * a List - * - * @return an AnnotationProps - * - */ - public AnnotationProps setXml(AnnotationConsts key, List<XmlObject> value) { - if (key.isSimpleType()) - throw new RuntimeException("Expect string value for annotation, not Xml Object [" + key + ", " + value - + "]"); - if (!key.isMultiValued()) - throw new RuntimeException("Expect single XML Object value for annotation, not List [" + key + ", " + value - + "]"); - - localMap.put(key, value); - return this; - } - - /** - * Use to add to existing multivalued string annotation - * - * @param key - * an AnnotationConsts - * @param value - * a String - * - * @return an AnnotationProps - * - */ - public AnnotationProps add(AnnotationConsts key, String value) { - if (!key.isSimpleType()) - throw new RuntimeException("Expect XML Object value for annotation, not String [" + key + ", " + value - + "]"); - if (!key.isMultiValued()) - throw new RuntimeException("Expect single XML Object value for annotation. use set, not add [" + key + ", " - + value + "]"); - - List<String> val = (List<String>) localMap.get(key); - if (val == null) { - val = new ArrayList<String>(); - localMap.put(key, val); - } - val.add(value); - return this; - } - - /** - * Use to add to existing multivalued XmlObj annotation - * - * @param key - * an AnnotationConsts - * @param value - * a XmlObject - * - * @return an AnnotationProps - * - */ - public AnnotationProps addXml(AnnotationConsts key, XmlObject value) { - if (key.isSimpleType()) - throw new RuntimeException("Expect string value for annotation, not Xml Object [" + key + ", " + value - + "]"); - if (!key.isMultiValued()) - throw new RuntimeException("Expect single XML Object value for annotation, use set, not add [" + key + ", " - + value + "]"); - - List<XmlObject> val = (List<XmlObject>) localMap.get(key); - if (val == null) { - val = new ArrayList<XmlObject>(); - localMap.put(key, val); - } - val.add(value); - return this; - } - - public String get(AnnotationConsts key) { - if (!key.isSimpleType()) - throw new RuntimeException("Expect XML Object value for annotation, not String" + " for anno: " + key); - if (key.isMultiValued()) - throw new RuntimeException("Expect list XML Object value for annotation, not single" + " for anno: " + key); - - return (String) localMap.get(key); - } - - public XmlObject getXml(AnnotationConsts key) { - if (key.isSimpleType()) - throw new RuntimeException("Expect string value for annotation, not Xml Object" + " for anno: " + key); - if (!key.isMultiValued()) - throw new RuntimeException("Expect list XML Object value for annotation, not single" + " for anno: " + key); - - return (XmlObject) localMap.get(key); - } - - public List<String> getAll(AnnotationConsts key) { - if (!key.isSimpleType()) - throw new RuntimeException("Expect XML Object value for annotation, not String" + " for anno: " + key); - if (!key.isMultiValued()) - throw new RuntimeException("Expect single XML Object value for annotation, not List" + " for anno: " + key); - - return (List<String>) localMap.get(key); - } - - public List<XmlObject> getAllXml(AnnotationConsts key) { - if (key.isSimpleType()) - throw new RuntimeException("Expect string value for annotation, not Xml Object" + " for anno: " + key); - if (!key.isMultiValued()) - throw new RuntimeException("Expect single XML Object value for annotation, not List" + " for anno: " + key); - - return (List<XmlObject>) localMap.get(key); - } - - public Set<AnnotationConsts> getKeys() { - return localMap.keySet(); - } - - public int size() { - return localMap.size(); - } - - @Override - public String toString() { - final StringBuffer anno = new StringBuffer(); - for (AnnotationConsts key : localMap.keySet()) { - if (key.isSimpleType()) { - if (key.isMultiValued()) { - // List<String> - List<String> values = (List<String>) localMap.get(key); - for (String val : values) { - addStartTag(anno, key); - anno.append(val); - addEndTag(anno, key); - } - } else { - // String - String val = (String) localMap.get(key); - addStartTag(anno, key); - anno.append(val); - addEndTag(anno, key); - } - } else { - if (key.isMultiValued()) { - // List<XmlObject> - List<XmlObject> values = (List<XmlObject>) localMap.get(key); - for (XmlObject val : values) { - addStartTag(anno, key); - anno.append(val.xmlText()); - addEndTag(anno, key); - } - } else { - // XmlObject - XmlObject val = (XmlObject) localMap.get(key); - addStartTag(anno, key); - anno.append(val.xmlText()); - addEndTag(anno, key); - } - } - } - return anno.toString(); - } - - private void addStartTag(StringBuffer anno, AnnotationConsts key) { - QName qname = key.getQName(); - anno.append('<'); - anno.append(qname.getLocalPart()); - if (qname.getNamespaceURI() != null) { - anno.append(" xmlns='"); - anno.append(qname.getNamespaceURI()); - anno.append('\''); - } - anno.append('>'); - } - - private void addEndTag(StringBuffer anno, AnnotationConsts key) { - anno.append("</"); - anno.append(key.getQName().getLocalPart()); - anno.append('>'); - } - -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/ConstructorConsts.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/ConstructorConsts.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/ConstructorConsts.java deleted file mode 100644 index f37b307..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/ConstructorConsts.java +++ /dev/null @@ -1,55 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -import org.apache.airavata.workflow.tracking.client.Callback; - -/** - * This contains the names of parameters passed to the notifier constructor. e.g. props = - * util.Props.newProps(CONSTS.WORKFLOW_ID, "wfId001"). set(CONSTS.NODE_ID, "nodeId001"). set(CONSTS.TIMESTEP, - * "time0001"). set(CONSTS.BROKER_URL, "rainier:12346")); Notifier notifier = NotifierFactory.createNotifier(props); - */ -public enum ConstructorConsts { - - NOTIFIER_IMPL_CLASS(String.class), ENABLE_BATCH_PROVENANCE(String.class), PUBLISHER_IMPL_CLASS(String.class), ENABLE_ASYNC_PUBLISH( - String.class), TOPIC(String.class), CALLBACK_LISTENER(Callback.class), BROKER_EPR(String.class), ANNOTATIONS( - AnnotationProps.class), KARMA_URL(String.class), KARMA_IMPL(Object.class); - - public Class getValueType() { - return valueType; - } - - public boolean checkValueType(Class otherType) { - if (otherType == null) - return false; - if (valueType.isAssignableFrom(otherType)) - return true; - else - return false; - } - - private Class valueType; - - private ConstructorConsts(Class type_) { - valueType = type_; - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/ConstructorProps.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/ConstructorProps.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/ConstructorProps.java deleted file mode 100644 index a0a6d4f..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/ConstructorProps.java +++ /dev/null @@ -1,68 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -import java.util.HashMap; -import java.util.Map; - -/** - * simple helper class to set properties as a chain. Extends Properties, so can be passed as constructor to notifier - * factory. can also load an external propetirs file that conforms to Java Properties file schema at - * http://java.sun.com/dtd/properties.dtd. - * - * e.g. props = util.Props.newProps(CONSTS.WORKFLOW_ID, "wfId001"). set(CONSTS.NODE_ID, "nodeId001"). - * set(CONSTS.TIMESTEP, "time0001"). set(CONSTS.BROKER_URL, "rainier:12346")); Notifier notifier = - * NotifierFactory.createNotifier(props); - */ -public class ConstructorProps { - - private Map<ConstructorConsts, Object> localMap; - - public ConstructorProps() { - localMap = new HashMap<ConstructorConsts, Object>(); - } - - public static ConstructorProps newProps() { - return new ConstructorProps(); - } - - public static ConstructorProps newProps(ConstructorConsts key, Object value) { - return newProps().set(key, value); - } - - public ConstructorProps set(ConstructorConsts key, Object value) { - if (!key.checkValueType(value.getClass())) - throw new ClassCastException("passed value class type: " + value.getClass() + " != expected class type: " - + key.getValueType() + " for key: " + key); - localMap.put(key, value); - return this; - } - - public Object get(ConstructorConsts key) { - return localMap.get(key); - } - - public Object get(ConstructorConsts key, Object defaultValue) { - Object value = localMap.get(key); - return value == null ? defaultValue : value; - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DataDurationObj.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DataDurationObj.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DataDurationObj.java deleted file mode 100644 index 7a6542b..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DataDurationObj.java +++ /dev/null @@ -1,35 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -import java.net.URI; - -/** - * Convinience class to record notification related information about a file/directory. - * - */ -public interface DataDurationObj extends DurationObj { - - public DataObj getDataObj(); - - public URI getRemoteLocation(); -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DataObj.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DataObj.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DataObj.java deleted file mode 100644 index 32ca95e..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DataObj.java +++ /dev/null @@ -1,42 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -import java.net.URI; -import java.util.List; - -/** - * Convinience class to record notification related information about a file/directory. - * - * - */ -public interface DataObj { - - public URI getId(); - - public URI getLocalLocation(); - - public List<URI> getLocations(); - - public long getSizeInBytes(); - -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DurationObj.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DurationObj.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DurationObj.java deleted file mode 100644 index 1f5a14c..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/DurationObj.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -/** - * Convinience class to record the state of computation related notifications. - */ -public interface DurationObj { - - public long markStartTimeMillis(); - - public long getStartTimeMillis(); - - public long markEndTimeMillis(); - - public long getEndTimeMillis(); - - public long getDurationMillis(); -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/InvocationContext.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/InvocationContext.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/InvocationContext.java deleted file mode 100644 index 95aa511..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/InvocationContext.java +++ /dev/null @@ -1,28 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -public interface InvocationContext extends InvocationEntity { - - public InvocationEntity getRemoteEntity(); - -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/InvocationEntity.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/InvocationEntity.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/InvocationEntity.java deleted file mode 100644 index 4d2e8fa..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/InvocationEntity.java +++ /dev/null @@ -1,39 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -import org.apache.airavata.workflow.tracking.types.BaseIDType; - -import java.net.URI; - -public interface InvocationEntity { - - public String getWorkflowNodeID(); - - public URI getServiceID(); - - public Integer getWorkflowTimestep(); - - public URI getWorkflowID(); - - public BaseIDType toBaseIDType(); -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/NotifierConfig.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/NotifierConfig.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/NotifierConfig.java deleted file mode 100644 index 32de5b2..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/NotifierConfig.java +++ /dev/null @@ -1,54 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -import org.apache.axis2.addressing.EndpointReference; - -public class NotifierConfig { - private EndpointReference bokerEpr; - private String publisherImpl; - private boolean enableAsyncPublishing; - - public EndpointReference getBokerEpr() { - return bokerEpr; - } - - public void setBokerEpr(EndpointReference bokerEpr) { - this.bokerEpr = bokerEpr; - } - - public String getPublisherImpl() { - return publisherImpl; - } - - public void setPublisherImpl(String publisherImpl) { - this.publisherImpl = publisherImpl; - } - - public boolean isEnableAsyncPublishing() { - return enableAsyncPublishing; - } - - public void setEnableAsyncPublishing(boolean enableAsyncPublishing) { - this.enableAsyncPublishing = enableAsyncPublishing; - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/NotifierCreationException.java ---------------------------------------------------------------------- diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/NotifierCreationException.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/NotifierCreationException.java deleted file mode 100644 index 33b8295..0000000 --- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/common/NotifierCreationException.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.airavata.workflow.tracking.common; - -public class NotifierCreationException extends NotifierException { - public NotifierCreationException(String msg) { - super(msg); - } - - public NotifierCreationException(Throwable ex) { - super(ex); - } -}
