You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2015/03/05 19:59:58 UTC
[1/2] airavata git commit: Removing the stale WS Messenger -
AIRAVATA-1556
Repository: airavata
Updated Branches:
refs/heads/master a18b747a5 -> 66de3728e
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/SimpleWorkflowExecution.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/SimpleWorkflowExecution.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/SimpleWorkflowExecution.java
deleted file mode 100644
index e8f6851..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/SimpleWorkflowExecution.java
+++ /dev/null
@@ -1,473 +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.test.suite.workflowtracking.tests.samples.workflow;
-
-import java.io.ByteArrayOutputStream;
-import java.net.URI;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Properties;
-import java.util.concurrent.Semaphore;
-
-import org.apache.airavata.workflow.tracking.GenericNotifier;
-import org.apache.airavata.workflow.tracking.Notifier;
-import org.apache.airavata.workflow.tracking.NotifierFactory;
-import org.apache.airavata.workflow.tracking.ProvenanceNotifier;
-import org.apache.airavata.workflow.tracking.WorkflowNotifier;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.airavata.workflow.tracking.common.AnnotationConsts;
-import org.apache.airavata.workflow.tracking.common.AnnotationProps;
-import org.apache.airavata.workflow.tracking.common.ConstructorConsts;
-import org.apache.airavata.workflow.tracking.common.ConstructorProps;
-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.airavata.wsmg.client.ConsumerNotificationHandler;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.axiom.soap.SOAPEnvelope;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.util.XMLPrettyPrinter;
-import org.apache.xmlbeans.XmlException;
-import org.apache.xmlbeans.XmlObject;
-import org.apache.xmlbeans.impl.tool.XSTCTester.TestCase;
-import org.junit.*;
-
-public class SimpleWorkflowExecution extends TestCase {
-
- /**
- * This class is not instantiated. So have a private default constructor.
- *
- */
- Subscription subscription;
- Properties configs = new Properties();
- String BROKER_URL = "http://127.0.0.1:8080/axis2/services/EventingService/topic/Foo";
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
-
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- // URL configURL = ClassLoader
- // .getSystemResource(TestConfigKeys.CONFIG_FILE_NAME);
- // configs.load(configURL.openStream());
- // BROKER_URL = configs
- // .getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
- // MESSAGEBOX_URL =
- // configs.getProperty(TestConfigKeys.MSGBOX_SERVICE_EPR);
- // consumerPort = Integer.parseInt(configs
- // .getProperty(TestConfigKeys.CONSUMER_PORT));
- // BROKER_EVENTING = configs
- // .getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
-
- DATA_URI_1 = new URI("lead:djsdhgfsdf");
- DATA_URI_2 = new URI("lead:skfdjhgkfg");
- DATA_URI_3 = new URI("lead:hgkdfhkgfd");
- DATA_URI_4 = new URI("lead:lshjkhdgdf");
- DATA_URI_5 = new URI("lead:fghkfhgfdg");
- DATA_URI_6 = new URI("lead:dshiuwekds");
-
- DATA_URLS_1 = Arrays.asList(new URI[] { new URI("http://dataserver/foo/1") });
- DATA_URLS_2 = Arrays.asList(new URI[] { new URI("http://dataserver/bar/2") });
- DATA_URLS_3 = Arrays.asList(new URI[] { new URI("http://dataserver/fubar/3"),
- new URI("http://datarepos/foobar/3") });
- DATA_URLS_4 = Arrays.asList(new URI[] { new URI("http://datarepos/fee/4") });
- DATA_URLS_5 = Arrays.asList(new URI[] { new URI("http://datarepos/fie/5") });
- DATA_URLS_6 = Arrays.asList(new URI[] { new URI("http://datarepos/foe/fum/6") });
-
- long now = System.currentTimeMillis();
- SERVICE_0 = new URI("http://tempuri.org/root_service/" + now);
- WORKFLOW_1 = new URI("http://tempuri.org/workflow1/" + now);
- SERVICE_1 = new URI("http://tempuri.org/service1/" + now);
- SERVICE_2 = new URI("http://tempuri.org/service2/" + now);
-
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- public URI WORKFLOW_1, SERVICE_1, SERVICE_2, SERVICE_0;
-
- private URI DATA_URI_1, DATA_URI_2, DATA_URI_3, DATA_URI_4, DATA_URI_5, DATA_URI_6;
- private List<URI> DATA_URLS_1, DATA_URLS_2, DATA_URLS_3, DATA_URLS_4, DATA_URLS_5, DATA_URLS_6;
-
- static class Success {
- XmlObject header;
- XmlObject body;
- }
-
- static class Failure {
- XmlObject header;
- XmlObject body;
- }
-
- public Object runWorkflow1(InvocationEntity myInvoker, URI myWorkflowID, URI myServiceID, String myNodeID,
- Integer myTimestep) throws XmlException {
-
- assert WORKFLOW_1.equals(myServiceID);
-
- WorkflowNotifier notifier = NotifierFactory.createWorkflowNotifier();
- WorkflowTrackingContext context = notifier.createTrackingContext(new Properties(), BROKER_URL, myWorkflowID,
- myServiceID, myNodeID, myTimestep);
-
- InvocationContext myInvocation = notifier.workflowInvoked(context, myInvoker,
- XmlObject.Factory.parse("<soapHeader/>"),
- XmlObject.Factory.parse("<soapBody>input1,input2</soapBody>"), "This is the start of this workflow");
-
- // BEGIN SERVICE1
- {
- // prepare to invoke service1
- InvocationEntity service1 = notifier.createEntity(myServiceID, SERVICE_1, "NODE1", 1);
- InvocationContext service1Invocation = notifier.invokingService(context, service1,
- XmlObject.Factory.parse("<soapHeader/>"), XmlObject.Factory.parse("<soapBody>input1</soapBody>"),
- "This workflow is invoking a service");
-
- Object result = null;
- try {
- // prepare to invoke service1
- result = runService1(service1, service1.getWorkflowID(), service1.getServiceID(),
- service1.getWorkflowNodeID(), service1.getWorkflowTimestep());
-
- // If this were an async invocation, we would have finished
- // sending request.
- // we acknowledge the successful request.
- notifier.invokingServiceSucceeded(context, service1Invocation, "Invoked service1 successfully");
-
- } catch (Exception ex) {
- // If there had been a problem sending the request on the wire,
- // we acknowledge a failed request.
- notifier.invokingServiceFailed(context, service1Invocation, ex, "Failed to invoke service1");
- }
-
- // At this point, we would have waited for response from service1 if
- // it were an async call.
- // assume we received response at this point and continue.
- if (result instanceof Success) {
- notifier.receivedResult(context, service1Invocation, ((Success) result).header,
- ((Success) result).body, "got success response from service1");
- } else if (result instanceof Failure) {
- notifier.receivedFault(context, service1Invocation, ((Failure) result).header, ((Failure) result).body,
- "got fault response from service1");
- }
-
- }
-
- // BEGIN SERVICE2
- {
- // prepare to invoke service1
- InvocationEntity service2 = notifier.createEntity(myServiceID, SERVICE_2, "NODE2", 2);
- InvocationContext service1Invocation = notifier.invokingService(context, service2,
- XmlObject.Factory.parse("<soapHeader/>"),
- XmlObject.Factory.parse("<soapBody>input2,input3</soapBody>"),
- "This workflow is invoking another service");
-
- Object result = null;
- try {
- // prepare to invoke service2
- result = runService2(service2, service2.getWorkflowID(), service2.getServiceID(),
- service2.getWorkflowNodeID(), service2.getWorkflowTimestep());
-
- // If this were an async invocation, we would have finished
- // sending request.
- // we acknowledge the successful request.
- notifier.invokingServiceSucceeded(context, service1Invocation, "Invoked service2 successfully");
-
- } catch (Exception ex) {
- // If there had been a problem sending the request on the wire,
- // we acknowledge a failed request.
- notifier.invokingServiceFailed(context, service1Invocation, ex, "Failed to invoke service2");
- }
-
- // At this point, we would have waited for response from service1 if
- // it were an async call.
- // assume we received response at this point and continue.
- if (result instanceof Success) {
- notifier.receivedResult(context, service1Invocation, ((Success) result).header,
- ((Success) result).body, "got success response from service2");
- } else if (result instanceof Failure) {
- notifier.receivedFault(context, service1Invocation, ((Failure) result).header, ((Failure) result).body,
- "got fault response from service2");
- }
-
- }
-
- Object result = null;
- notifier.sendingResult(context, myInvocation, "sending result back to the invoker of this workflow");
- try {
- result = new Success();
- notifier.sendingResponseSucceeded(context, myInvocation, "sent result to invoker");
- } catch (Exception ex) {
- notifier.sendingResponseFailed(context, myInvocation, ex);
- }
-
- return result;
- }
-
- public Object runService1(InvocationEntity myInvoker, URI myWorkflowID, URI myServiceID, String myNodeID,
- int myTimestep) throws XmlException {
-
- // ensure the service ID as passed is what the service thinks it's
- // service ID is
- assert SERVICE_1.equals(myServiceID);
-
- // if we were not publishing data products, a serviceNotifier would have
- // sufficed
- ProvenanceNotifier notifier = NotifierFactory.createProvenanceNotifier();
- WorkflowTrackingContext context = notifier.createTrackingContext(null, BROKER_URL, myWorkflowID, myServiceID,
- myNodeID, myTimestep);
- InvocationContext invocationContext = notifier.serviceInvoked(context, myInvoker,
- "I (service1) was invoked by my invoker",
- AnnotationProps.newProps(AnnotationConsts.AbstractServiceID, myServiceID.toString() + "-abstract")
- .toString());
-
- notifier.dataConsumed(context, DATA_URI_1, DATA_URLS_1, "consuming a file");
- notifier.dataConsumed(context, DATA_URI_2, DATA_URLS_2, "consuming another file");
-
- // do stuff!
-
- notifier.dataProduced(context, DATA_URI_3, DATA_URLS_3, "produced some file", "<someXml/>");
-
- boolean successResult = true;
-
- // produce response...either success or failure
- Object result = null;
- if (successResult) {
- Success success = new Success();
- success.header = XmlObject.Factory
- .parse("<S:Header "
- + "xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:wsa=\"http://www.w3.org/2005/08/addressing\" xmlns:wsp=\"http://schemas.xmlsoap.org/ws/2002/12/policy\" xmlns:S=\"http://schemas.xmlsoap.org/soap/envelope/\">"
- + "<wsa:To>http://129.79.246.253:3456</wsa:To><wsa:RelatesTo>uuid:ee4d14d0-2262-11db-86d8-cd518af91949</wsa:RelatesTo>"
- + "</S:Header>");
- success.body = XmlObject.Factory
- .parse("<S:Body "
- + "xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:wsa=\"http://www.w3.org/2005/08/addressing\" xmlns:wsp=\"http://schemas.xmlsoap.org/ws/2002/12/policy\" xmlns:S=\"http://schemas.xmlsoap.org/soap/envelope/\">"
- + "<gfac:Run_OutputParams xmlns:gfac=\"http://org.apache.airavata/namespaces/2004/01/gFac\">"
- + "<gfac:WRF_Ininitialization_Files><value>gsiftp://grid-hg.ncsa.teragrid.org//scratch/hperera/Wed_Aug_02_15_10_23_EST_2006_ARPS2WRF/outputData/namelist.input</value><value>gsiftp://grid-hg.ncsa.teragrid.org//scratch/hperera/Wed_Aug_02_15_10_23_EST_2006_ARPS2WRF/outputData/wrfbdy_d01</value><value>gsiftp://grid-hg.ncsa.teragrid.org//scratch/hperera/Wed_Aug_02_15_10_23_EST_2006_ARPS2WRF/outputData/wrfinput_d01</value></gfac:WRF_Ininitialization_Files>"
- + "</gfac:Run_OutputParams>" + "</S:Body>");
-
- // notify that invocation produced a result and send result to
- // invoker
- notifier.sendingResult(context, invocationContext, success.header, success.body, "sending success");
- try {
- // since this is a sync call, we mimic an async response by
- // seting the result object
- result = success;
- // acknowledge that the result was sent successfully
- notifier.sendingResponseSucceeded(context, invocationContext);
- } catch (Exception ex) {
- // acknowledge that sending the result failed
- notifier.sendingResponseFailed(context, invocationContext, ex, "error sending response");
- }
-
- } else {
-
- Failure failure = new Failure();
- failure.header = XmlObject.Factory.parse("<faultHeader/>");
- failure.body = XmlObject.Factory.parse("<faultBody>fault1</faultBody>");
-
- // notify that invocation produced a fault and send fault to invoker
- notifier.sendingFault(context, invocationContext, failure.header, failure.body, "sending fault");
- try {
- // since this is a sync call, we mimic an async response by
- // seting the result object
- result = failure;
- // acknowledge that the fault was sent successfully
- notifier.sendingResponseSucceeded(context, invocationContext);
- } catch (Exception ex) {
- // acknowledge that sending the fault failed
- notifier.sendingResponseFailed(context, invocationContext, ex, "error sending response");
- }
- }
-
- // send result
- return result;
- }
-
- public Object runService2(InvocationEntity myInvoker, URI myWorkflowID, URI myServiceID, String myNodeID,
- int myTimestep) throws XmlException {
-
- // ensure the service ID as passed is what the service thinks it's
- // service ID is
- assert SERVICE_2.equals(myServiceID);
-
- // if we were not publishing data products, a serviceNotifier would have
- // sufficed
- ProvenanceNotifier notifier = NotifierFactory.createProvenanceNotifier();
-
- // received request
- WorkflowTrackingContext context = notifier.createTrackingContext(null, BROKER_URL, myWorkflowID, myServiceID,
- myNodeID, myTimestep);
- InvocationContext invocationContext = notifier.serviceInvoked(context, myInvoker,
- "I (service2) was invoked by my invoker");
-
- notifier.dataConsumed(context, DATA_URI_2, DATA_URLS_2, "consuming file used by service1");
- notifier.dataConsumed(context, DATA_URI_3, DATA_URLS_3);
- notifier.dataConsumed(context, DATA_URI_4, DATA_URLS_4, null, "<dataXml>boo</dataXml>");
-
- // do stuff!
-
- notifier.dataProduced(context, DATA_URI_5, DATA_URLS_5);
- notifier.dataProduced(context, DATA_URI_6, DATA_URLS_6);
-
- boolean successResult = true;
-
- // produce response...either success or failure
- Object result = null;
- if (successResult) {
- Success success = new Success();
- success.header = XmlObject.Factory.parse("<resultHeader/>");
- success.body = XmlObject.Factory.parse("<resultBody>output2,output3</resultBody>");
-
- // notify that invocation produced a result and send result to
- // invoker
- notifier.sendingResult(context, invocationContext, success.header, success.body, "sending success");
- try {
- // since this is a sync call, we mimic an async response by
- // seting the result object
- result = success;
- // acknowledge that the result was sent successfully
- notifier.sendingResponseSucceeded(context, invocationContext);
- } catch (Exception ex) {
- // acknowledge that sending the result failed
- notifier.sendingResponseFailed(context, invocationContext, ex, "error sending response");
- }
-
- } else {
-
- Failure failure = new Failure();
- failure.header = XmlObject.Factory.parse("<faultHeader/>");
- failure.body = XmlObject.Factory.parse("<faultBody>fault2</faultBody>");
-
- // notify that invocation produced a fault and send fault to invoker
- notifier.sendingFault(context, invocationContext, failure.header, failure.body, "sending fault");
- try {
- // since this is a sync call, we mimic an async response by
- // seting the result object
- result = failure;
- // acknowledge that the fault was sent successfully
- notifier.sendingResponseSucceeded(context, invocationContext);
- } catch (Exception ex) {
- // acknowledge that sending the fault failed
- notifier.sendingResponseFailed(context, invocationContext, ex, "error sending response");
- }
- }
-
- // send result
- return result;
- }
-
- // used to override notifier creation to use an external notifier, instead
- // of setting the
- // properties to create it in the main method
- private Notifier notifier;
-
- public void runSample() throws Exception {
- notifier = NotifierFactory.createNotifier();
- WorkflowTrackingContext context = notifier.createTrackingContext(null, BROKER_URL, WORKFLOW_1, SERVICE_0, null,
- null);
- // create workflow and service instances
- {
-
- WorkflowNotifier notifier = NotifierFactory.createWorkflowNotifier();
- notifier.workflowInitialized(context, WORKFLOW_1, "Workflow ready to start",
- "<wfInfo>some annotation about the workflow</wfInfo>",
- "<dummy>just to check annotations list</dummy>");
- notifier.serviceInitialized(context, SERVICE_1);
- notifier.serviceInitialized(context, SERVICE_2);
- }
-
- {
- GenericNotifier notifier = NotifierFactory.createGenericNotifier();
- InvocationEntity initiatingService = notifier.createEntity(null, SERVICE_0, null, null);
-
- runWorkflow1(initiatingService, null, WORKFLOW_1, null, null);
- }
-
- // terminate workflow and service instances
- {
- WorkflowNotifier notifier = NotifierFactory.createWorkflowNotifier();
- notifier.workflowTerminated(context, WORKFLOW_1);
- notifier.serviceTerminated(context, SERVICE_1);
- notifier.serviceTerminated(context, SERVICE_2);
- }
- }
-
- @Test
- public void testSimpleTest() throws Exception {
-
- System.out.println("USAGE: run org.apache.airavata.workflow.tracking.samples.workflow.SimpleWorkflowExecution "
- + " [WSMessaging broker URL (default: print to stdout)]");
-
- ConsumerNotificationHandler handler = new ConsumerNotificationHandler() {
-
- public void handleNotification(SOAPEnvelope msgEnvelope) {
- try {
- ByteArrayOutputStream out = new ByteArrayOutputStream();
- XMLPrettyPrinter.prettify(msgEnvelope, out);
- System.out.println(new String(out.toByteArray()));
- } catch (Exception e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- };
-
- WseMsgBrokerClient api = new WseMsgBrokerClient();
- api.init(BROKER_URL);
- int consumerPort = 5555;
-
- String[] consumerServiceEprs = api.startConsumerService(consumerPort, handler);
-
- api.subscribe(consumerServiceEprs[0], ">", null);
-
- String topic = "Foo";
- // if remote broker location specified, use WSMessaging publisher;
- ConstructorProps props = ConstructorProps
- .newProps(ConstructorConsts.ENABLE_ASYNC_PUBLISH, "false")
- .set(ConstructorConsts.ENABLE_BATCH_PROVENANCE, "true")
- .set(ConstructorConsts.ANNOTATIONS,
- AnnotationProps.newProps(AnnotationConsts.ExperimentID,
- "experiment-id-" + System.currentTimeMillis()).set(AnnotationConsts.UserDN,
- "/O=IU/OU=Extreme Lab/CN=drlead"));
- if (BROKER_URL != null) {
- EndpointReference brokerEpr = api.createEndpointReference(BROKER_URL, topic);
-
- props.set(ConstructorConsts.BROKER_EPR, brokerEpr.getAddress());
- } else {
- props.set(ConstructorConsts.PUBLISHER_IMPL_CLASS,
- "org.apache.airavata.workflow.tracking.impl.publish.LoopbackPublisher");
- props.set(ConstructorConsts.TOPIC, topic);
- }
-
- System.out.println(ConstructorConsts.ANNOTATIONS);
- System.out.println(ConstructorConsts.KARMA_IMPL);
- runSample();
- new Semaphore(0).acquire();
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/WorkflowNotificationListener.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/WorkflowNotificationListener.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/WorkflowNotificationListener.java
deleted file mode 100644
index de41ebb..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/WorkflowNotificationListener.java
+++ /dev/null
@@ -1,127 +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.test.suite.workflowtracking.tests.samples.workflow;
-
-import java.net.URL;
-import java.rmi.RemoteException;
-import java.util.Properties;
-
-import org.apache.airavata.workflow.tracking.client.Callback;
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.TestConfigKeys;
-import org.apache.airavata.workflow.tracking.types.WorkflowTerminatedDocument;
-import org.apache.xmlbeans.XmlException;
-import org.apache.xmlbeans.XmlObject;
-import org.junit.*;
-
-public class WorkflowNotificationListener implements Callback {
-
- Subscription subscription;
- Properties configs = new Properties();
- String BROKER_URL;
- String MESSAGEBOX_URL;
- int consumerPort;
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
-
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- URL configURL = ClassLoader.getSystemResource(TestConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
- BROKER_URL = configs.getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
- MESSAGEBOX_URL = configs.getProperty(TestConfigKeys.MSGBOX_SERVICE_EPR);
- consumerPort = Integer.parseInt(configs.getProperty(TestConfigKeys.CONSUMER_PORT));
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- public WorkflowNotificationListener() {
- }
-
- /**
- * 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 type, XmlObject messageObj) {
-
- System.out.println("Received Notification Type [" + type + "] on topic [" + topic + "]\n" + messageObj
- + "\n---");
-
- if (type == NotificationType.WorkflowTerminated) {
- System.out.println("Workflow terminated. Unsubscribing...");
- WorkflowTerminatedDocument obj = (WorkflowTerminatedDocument) messageObj;
- try {
- obj.getWorkflowTerminated().getAnnotation()
- .set(XmlObject.Factory.parse("<something>someval</something>"));
- System.out.println(obj.toString());
- } catch (XmlException e) {
- e.printStackTrace();
- }
- try {
- subscription.destroy();
- } catch (RemoteException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- }
-
- @Test
- public void testWokflowNotificationListener() throws Exception {
-
- String topic = "somerandomtopic";
-
- WorkflowNotificationListener subscriber = new WorkflowNotificationListener();
- boolean useMessageBox = true;
- if (!useMessageBox) {
- subscription = LeadNotificationManager.createSubscription(BROKER_URL, topic, subscriber, consumerPort);
- } else {
- subscription = LeadNotificationManager.createMessageBoxSubscription(MESSAGEBOX_URL, BROKER_URL, topic,
- null, subscriber);
- }
- System.out.println("Subscribing to broker: " + BROKER_URL);
- System.out.println("Started listening on topic: " + subscription.getTopic());
- while (true) {
- Thread.sleep(10000);
- }
-
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/CommonUtils.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/CommonUtils.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/CommonUtils.java
deleted file mode 100644
index 740c0fa..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/CommonUtils.java
+++ /dev/null
@@ -1,26 +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.test.suite.workflowtracking.tests.util;
-
-public class CommonUtils {
- public static final String WORKFLOW_INITIALIZED_NOTIFICATION = "<wor:workflowInitialized xmlns:wor=\"http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking\"><wor:notificationSource wor:serviceID=\"http://tempuri.org/workflow1\" /><wor:timestamp>2006-06-04T00:53:41.296-04:00</wor:timestamp></wor:workflowInitialized>";
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/SubscriberThread.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/SubscriberThread.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/SubscriberThread.java
deleted file mode 100644
index 6adcf6a..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/SubscriberThread.java
+++ /dev/null
@@ -1,91 +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.test.suite.workflowtracking.tests.util;
-
-import java.rmi.RemoteException;
-
-import org.apache.airavata.workflow.tracking.client.Callback;
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.airavata.test.suite.workflowtracking.tests.MultipleSubscriptionTest;
-import org.apache.airavata.test.suite.workflowtracking.tests.ThreadMessagePassingCallback;
-import org.apache.xmlbeans.XmlObject;
-
-public class SubscriberThread extends Thread {
-
- private ThreadMessagePassingCallback callback;
-
- public static int count = 0;
-
- private int subCount = 0;
-
- private Subscription subscription;
- private String brokerURL;
- private String topic;
- private int consumerServerPort;
-
- public SubscriberThread(ThreadMessagePassingCallback callback, String brokerURL, String topic,
- int consumerServerPort) {
- this.callback = callback;
- this.brokerURL = brokerURL;
- this.topic = topic;
- this.consumerServerPort = consumerServerPort;
- }
-
- @Override
- public void run() {
- try {
- subscription = LeadNotificationManager.createSubscription(brokerURL, topic, new Callback() {
-
- public void deliverMessage(String topic, NotificationType type, XmlObject messageObj) {
-
- subCount++;
- count++;
- System.out.println("Subscription received " + subCount + "th notification of type:" + type
- + " Total is :" + count);
- assert (type == NotificationType.WorkflowInitialized);
-
- if (subCount == MultipleSubscriptionTest.NOTIFICATIONS_PUBLISHED) {
- try {
- subscription.destroy();
- } catch (RemoteException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- callback.done();
- }
- }
- }, consumerServerPort);
- } catch (Exception e) {
- e.printStackTrace();
- }
- while (true) {
- try {
- Thread.sleep(10000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/TestConfigKeys.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/TestConfigKeys.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/TestConfigKeys.java
deleted file mode 100644
index ec3d466..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/util/TestConfigKeys.java
+++ /dev/null
@@ -1,34 +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.test.suite.workflowtracking.tests.util;
-
-public class TestConfigKeys {
- public final static String CONFIG_FILE_NAME = "unit_test.properties";
- public final static String BROKER_EVENTING_SERVICE_EPR = "broker.eventing.service.epr";
- public final static String BROKER_NOTIFICATIONS_SERVICE_EPR = "broker.notification.service.epr";
- public final static String MSGBOX_SERVICE_EPR = "msgbox.service.epr";
- public final static String CONSUMER_EPR = "consumer.location";
- public final static String CONSUMER_PORT = "consumer.port";
- public final static String TOPIC_SIME = "topic.simple";
- public final static String TOPIC_XPATH = "topic.xpath";
- public final static String AXIS2_REPO = "axis2.repo";
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/resources/gram.properties.template
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/resources/gram.properties.template b/modules/test-suite/src/test/resources/gram.properties.template
deleted file mode 100644
index 7e06a83..0000000
--- a/modules/test-suite/src/test/resources/gram.properties.template
+++ /dev/null
@@ -1,70 +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.
-#
-
-# The myproxy server to retrieve the grid credentials
-myproxy.server=
-# Example: XSEDE myproxy server
-#myproxy.server=myproxy.teragrid.org
-
-# The user name and password to fetch grid proxy
-myproxy.username=
-myproxy.password=
-
-#Directory with Grid Certification Authority certificates and CRL's
-# The certificates for XSEDE can be downloaded from http://software.xsede.org/security/xsede-certs.tar.gz
-ca.certificates.directory=
-
-# On computational grids, an allocation is awarded with a charge number. On XSEDE, the numbers are typically of
-# the format TG-DIS123456
-allocation.charge.number=
-
-# The scratch space with ample space to create temporary working directory on target compute cluster
-scratch.working.directory=
-
-# Name, FQDN, and gram and gridftp end points of the remote compute cluster
-host.commom.name=
-host.fqdn.name=
-gridftp.endpoint=
-gram.endpoints=
-defualt.queue=
-
-# Example compute hosts on XSEDE
-#host.commom.name=Ranger
-#host.fqdn.name=ranger.tacc.teragrid.org
-#gridftp.endpoint=gsiftp://gridftp.ranger.tacc.teragrid.org:2811/
-#gram.endpoints=gatekeeper.ranger.tacc.teragrid.org:2119/jobmanager-sge
-#defualt.queue=
-
-#host.commom.name=Lonestar
-#host.fqdn.name=lonestar4.tacc.teragrid.org
-#gridftp.endpoint=gsiftp://gridftp1.ls4.tacc.utexas.edu:2811/
-#gram.endpoints=gridftp1.ls4.tacc.utexas.edu:2119/jobmanager-sge
-#defualt.queue=
-
-#host.commom.name=Trestles
-#host.fqdn.name=trestles.sdsc.teragrid.org
-#gridftp.endpoint=gsiftp://trestles.sdsc.edu:2811/
-#gram.endpoints=trestles.sdsc.edu:2119/jobmanager-pbs
-#defualt.queue=
-
-#host.commom.name=Ember
-#host.fqdn.name=ember.ncsa.teragrid.org
-#gridftp.endpoint=grid-ember.ncsa.teragrid.org:2811/
-#gram.endpoints=grid-ember.ncsa.teragrid.org:2120/jobmanager-pbs
-#defualt.queue=normal
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/resources/unit_test.properties
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/resources/unit_test.properties b/modules/test-suite/src/test/resources/unit_test.properties
deleted file mode 100644
index 31d7c8c..0000000
--- a/modules/test-suite/src/test/resources/unit_test.properties
+++ /dev/null
@@ -1,26 +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.
-#
-
-broker.eventing.service.epr=http://localhost:8080/axis2/services/EventingService
-broker.notification.service.epr=http://localhost:8080/axis2/services/NotificationService
-msgbox.service.epr=http://localhost:8080/axis2/services/MsgBoxService
-consumer.port=2222
-consumer.location=http://localhost:2222
-topic.simple=MySimpleTestTopic
-topic.xpath=MyXpathTextTopic
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 82ea635..512f21d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -602,7 +602,6 @@
<module>airavata-api</module>
<module>modules/commons</module>
<module>modules/gfac</module>
- <!--<module>modules/ws-messenger</module>-->
<module>modules/workflow-model</module>
<module>modules/registry</module>
<module>modules/security</module>
@@ -610,7 +609,6 @@
<module>modules/orchestrator</module>
<module>tools</module>
<module>modules/server</module>
- <!--<module>modules/test-suite</module>-->
<module>modules/distribution</module>
<module>modules/integration-tests</module>
</modules>
[2/2] airavata git commit: Removing the stale WS Messenger -
AIRAVATA-1556
Posted by sm...@apache.org.
Removing the stale WS Messenger - AIRAVATA-1556
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/66de3728
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/66de3728
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/66de3728
Branch: refs/heads/master
Commit: 66de3728edcfbd787c7204460bf66e59b4930705
Parents: a18b747
Author: Suresh Marru <sm...@apache.org>
Authored: Thu Mar 5 13:56:09 2015 -0500
Committer: Suresh Marru <sm...@apache.org>
Committed: Thu Mar 5 13:56:09 2015 -0500
----------------------------------------------------------------------
modules/test-suite/pom.xml | 116 -----
.../tests/LeadCallbackHandlerTest.java | 173 -------
.../tests/LeadNotificationManagerTest.java | 49 --
.../tests/MultipleSubscriptionTest.java | 105 ----
.../tests/RenewSubscriptionTest.java | 155 ------
.../tests/ThreadMessagePassingCallback.java | 27 --
.../tests/impl/publish/Test.java | 40 --
.../tests/impl/publish/TestWSMPublisher.java | 119 -----
.../tests/messagebox/MessagePullerTest.java | 140 ------
.../MultipleSubscriptionForMessageBoxTest.java | 118 -----
.../tests/messagebox/RenewSubscriptionTest.java | 109 -----
.../tests/messagebox/SubscriberThread.java | 96 ----
.../restart/MessageBoxClientRestartTest.java | 131 -----
.../restart/MessageBoxCreateThread.java | 83 ----
.../tests/samples/workflow/SimpleTest.java | 202 --------
.../workflow/SimpleWorkflowExecution.java | 473 -------------------
.../workflow/WorkflowNotificationListener.java | 127 -----
.../tests/util/CommonUtils.java | 26 -
.../tests/util/SubscriberThread.java | 91 ----
.../tests/util/TestConfigKeys.java | 34 --
.../src/test/resources/gram.properties.template | 70 ---
.../src/test/resources/unit_test.properties | 26 -
pom.xml | 2 -
23 files changed, 2512 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/pom.xml
----------------------------------------------------------------------
diff --git a/modules/test-suite/pom.xml b/modules/test-suite/pom.xml
deleted file mode 100644
index ddd555d..0000000
--- a/modules/test-suite/pom.xml
+++ /dev/null
@@ -1,116 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!--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. -->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- <parent>
- <groupId>org.apache.airavata</groupId>
- <artifactId>airavata</artifactId>
- <version>0.15-SNAPSHOT</version>
- <relativePath>../../pom.xml</relativePath>
- </parent>
-
- <modelVersion>4.0.0</modelVersion>
- <artifactId>test-suite</artifactId>
- <name>Airavata Test Suite</name>
- <description>Airavata Test Suite</description>
- <url>http://airavata.apache.org/</url>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.axis2</groupId>
- <artifactId>axis2-transport-local</artifactId>
- <version>${axis2.version}</version>
- <scope>compile</scope>
- </dependency>
-
-
- <dependency>
- <groupId>org.bouncycastle</groupId>
- <artifactId>bcprov-jdk15on</artifactId>
- </dependency>
- <dependency>
- <groupId>commons-configuration</groupId>
- <artifactId>commons-configuration</artifactId>
- <version>1.6</version>
- </dependency>
-
- <!-- Logging -->
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-api</artifactId>
- </dependency>
-
- <!-- GFAC schemas -->
- <!--<dependency>-->
- <!--<groupId>org.apache.airavata</groupId>-->
- <!--<artifactId>airavata-gfac-schema-utils</artifactId>-->
- <!--<version>${project.version}</version>-->
- <!--</dependency>-->
- <dependency>
- <groupId>org.apache.airavata</groupId>
- <artifactId>airavata-gfac-core</artifactId>
- <version>${project.version}</version>
- </dependency>
-
- <!-- Workflow Tracking -->
- <!--<dependency>-->
- <!--<groupId>org.apache.airavata</groupId>-->
- <!--<artifactId>airavata-workflow-tracking</artifactId>-->
- <!--<version>${project.version}</version>-->
- <!--</dependency>-->
-
- <!-- SSH -->
- <dependency>
- <groupId>net.schmizz</groupId>
- <artifactId>sshj</artifactId>
- <version>0.5.0</version>
- </dependency>
-
- <!-- Amazon -->
- <dependency>
- <groupId>com.amazonaws</groupId>
- <artifactId>aws-java-sdk</artifactId>
- <version>1.3.20</version>
- </dependency>
-
- <!-- Test -->
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>jcl-over-slf4j</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-log4j12</artifactId>
- <scope>test</scope>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <!-- Set working directory to test-class directory -->
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-surefire-plugin</artifactId>
- <inherited>true</inherited>
- <configuration>
- <workingDirectory>${project.build.testOutputDirectory}</workingDirectory>
- <skipTests>true</skipTests>
- </configuration>
- <version>${surefire.version}</version>
- </plugin>
- </plugins>
- </build>
-</project>
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/LeadCallbackHandlerTest.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/LeadCallbackHandlerTest.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/LeadCallbackHandlerTest.java
deleted file mode 100644
index 2f527cc..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/LeadCallbackHandlerTest.java
+++ /dev/null
@@ -1,173 +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.test.suite.workflowtracking.tests;
-
-import java.io.StringReader;
-import java.net.URL;
-import java.util.Properties;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
-
-import org.apache.airavata.commons.WorkFlowUtils;
-import org.apache.airavata.workflow.tracking.client.Callback;
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.CommonUtils;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.TestConfigKeys;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.axiom.om.OMElement;
-import org.apache.xmlbeans.XmlObject;
-import org.apache.xmlbeans.impl.tool.XSTCTester.TestCase;
-import org.junit.*;
-
-public class LeadCallbackHandlerTest extends TestCase {
-
- Properties configs = new Properties();
- String BROKER_URL;
- String MESSAGEBOX_URL;
- int consumerPort;
- String AXIS_REPO;
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
-
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- URL configURL = ClassLoader.getSystemResource(TestConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
- BROKER_URL = configs.getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
- MESSAGEBOX_URL = configs.getProperty(TestConfigKeys.MSGBOX_SERVICE_EPR);
- consumerPort = Integer.parseInt(configs.getProperty(TestConfigKeys.CONSUMER_PORT));
- AXIS_REPO = configs.getProperty(TestConfigKeys.AXIS2_REPO);
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- boolean wait = false;
- int repetition = 3;
- private Subscription subscription;
-
- class TestMsgCallback implements Callback {
-
- public TestMsgCallback(int reps) {
- repititions = reps;
- }
-
- BlockingQueue<Boolean> msgQueue = new LinkedBlockingQueue<Boolean>();
- int count = 0;
- int repititions;
-
- public void deliverMessage(String topic, NotificationType notificationType, XmlObject messageObj) {
-
- count++;
- System.out.println("Subscription received " + count + "th notification of type:");
- if (repititions <= count) {
- msgQueue.add(new Boolean(true));
- }
-
- }
-
- public BlockingQueue<Boolean> getQueue() {
- return msgQueue;
- }
-
- }
-
- @Test
- public void testRoundTrip() throws Exception {
- wait = true;
-
- TestMsgCallback c1 = new TestMsgCallback(repetition);
- TestMsgCallback c2 = new TestMsgCallback(repetition);
-
- subscription = LeadNotificationManager.createSubscription(BROKER_URL, "topic", c1, consumerPort);
- Thread.sleep(100);
- Subscription subscription2 = LeadNotificationManager.createSubscription(BROKER_URL, "topic", c2,
- consumerPort + 1);
-
- WseMsgBrokerClient client = new WseMsgBrokerClient();
- client.init(BROKER_URL);
- client.setTimeoutInMilliSeconds(20000L);
-
- OMElement msg = WorkFlowUtils.reader2OMElement(new StringReader(CommonUtils.WORKFLOW_INITIALIZED_NOTIFICATION));
-
- for (int i = 0; i < repetition; i++) {
- client.publish("topic", msg);
- Thread.sleep(100);
- }
-
- Boolean b1 = c1.getQueue().take();
- Boolean b2 = c2.getQueue().take();
-
- System.out.println(b1);
- System.out.println(b2);
-
- subscription.destroy();
- subscription2.destroy();
-
- }
-
- @Test
- public void testRoundTripWithDifferentTopics() throws Exception {
- wait = true;
-
- TestMsgCallback c1 = new TestMsgCallback(repetition);
- TestMsgCallback c2 = new TestMsgCallback(repetition);
-
- subscription = LeadNotificationManager.createSubscription(BROKER_URL, "topic10", c1, consumerPort);
- Subscription subscription2 = LeadNotificationManager.createSubscription(BROKER_URL, "topic20", c2,
- consumerPort + 1);
-
- WseMsgBrokerClient client = new WseMsgBrokerClient();
- client.init(BROKER_URL);
-
- OMElement msg = WorkFlowUtils.reader2OMElement(new StringReader(CommonUtils.WORKFLOW_INITIALIZED_NOTIFICATION));
-
- for (int i = 0; i < repetition; i++) {
- client.publish("topic10", msg);
- Thread.sleep(100);
- }
-
- for (int i = 0; i < repetition; i++) {
- client.publish("topic20", msg);
- Thread.sleep(100);
- }
-
- Boolean b1 = c1.getQueue().take();
- Boolean b2 = c2.getQueue().take();
-
- System.out.println(b1);
- System.out.println(b2);
-
- subscription2.destroy();
- subscription.destroy();
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/LeadNotificationManagerTest.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/LeadNotificationManagerTest.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/LeadNotificationManagerTest.java
deleted file mode 100644
index f302481..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/LeadNotificationManagerTest.java
+++ /dev/null
@@ -1,49 +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.test.suite.workflowtracking.tests;
-
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.junit.After;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
-
-public class LeadNotificationManagerTest {
-
- @Before
- public void setUp() throws Exception {
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- @Test
- public final void testGetBrokerPublishEPR() {
-
- String endpointRefAsStr = LeadNotificationManager.getBrokerPublishEPR("http://localhost:8080/axis2/services/EventingService", "testtopic");
-
- Assert.assertEquals("<EndpointReference><wsa:Address xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">http://localhost:8080/axis2/services/EventingService/topic/testtopic</wsa:Address></EndpointReference>",endpointRefAsStr);
-
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/MultipleSubscriptionTest.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/MultipleSubscriptionTest.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/MultipleSubscriptionTest.java
deleted file mode 100644
index cb297a2..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/MultipleSubscriptionTest.java
+++ /dev/null
@@ -1,105 +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.test.suite.workflowtracking.tests;
-
-import java.net.URL;
-import java.util.Properties;
-
-import org.apache.airavata.test.suite.workflowtracking.tests.util.CommonUtils;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.SubscriberThread;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.TestConfigKeys;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.xmlbeans.impl.tool.XSTCTester.TestCase;
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-
-public class MultipleSubscriptionTest extends TestCase implements ThreadMessagePassingCallback {
-
- static Properties configs = new Properties();
- String BROKER_URL;
- String MESSAGEBOX_URL;
- int consumerPort;
- public static final int NOTIFICATIONS_PUBLISHED = 4;
- public static final int NUMBER_OF_SUBSCRIBERS = 4;
- private int succesfulclients = 0;
- String AXIS_REPO;
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
-
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- URL configURL = ClassLoader.getSystemResource(TestConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
- BROKER_URL = configs.getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
- MESSAGEBOX_URL = configs.getProperty(TestConfigKeys.MSGBOX_SERVICE_EPR);
- consumerPort = Integer.parseInt(configs.getProperty(TestConfigKeys.CONSUMER_PORT));
- AXIS_REPO = configs.getProperty(TestConfigKeys.AXIS2_REPO);
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- public void testMultipleSubscribers() throws Exception {
-
- SubscriberThread[] subscribers = new SubscriberThread[NUMBER_OF_SUBSCRIBERS];
- for (int i = 0; i < NUMBER_OF_SUBSCRIBERS; ++i) {
- subscribers[i] = new SubscriberThread(this, BROKER_URL, "topic" + i, consumerPort + i);
- subscribers[i].start();
-
- }
-
- Thread.sleep(5000);
-
- WseMsgBrokerClient client = new WseMsgBrokerClient();
- client.init(BROKER_URL);
-
- for (int j = 0; j < NUMBER_OF_SUBSCRIBERS; j++) {
- for (int i = 0; i < NOTIFICATIONS_PUBLISHED; i++) {
-
- client.publish("topic" + j, CommonUtils.WORKFLOW_INITIALIZED_NOTIFICATION);
-
- Thread.sleep(100);
- }
- }
-
- while (succesfulclients < NUMBER_OF_SUBSCRIBERS) {
- Thread.sleep(1000);
- }
-
- }
-
- public void done() {
- System.out.println("Done Multiple subscription test");
- succesfulclients++;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/RenewSubscriptionTest.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/RenewSubscriptionTest.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/RenewSubscriptionTest.java
deleted file mode 100644
index 6428e8e..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/RenewSubscriptionTest.java
+++ /dev/null
@@ -1,155 +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.test.suite.workflowtracking.tests;
-
-import java.net.URL;
-import java.rmi.RemoteException;
-import java.util.Properties;
-
-import org.apache.airavata.workflow.tracking.client.Callback;
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.TestConfigKeys;
-import org.apache.airavata.wsmg.client.MsgBrokerClientException;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.axis2.AxisFault;
-import org.apache.xmlbeans.XmlObject;
-import org.apache.xmlbeans.impl.tool.XSTCTester.TestCase;
-import org.junit.*;
-
-public class RenewSubscriptionTest extends TestCase implements Callback {
-
- static Properties configs = new Properties();
- String BROKER_URL;
- String MESSAGEBOX_URL;
- int consumerPort;
- public static final String TOPIC = "testTopic";
- private static final String MESSAGE_BOX_ID = "929799u028887273u9899400999999";
- public static int count = 0;
- public int messages = 10;
- public static Object mutex = new Object();
- Subscription sub;
- String AXIS_REPO;
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
-
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- URL configURL = ClassLoader.getSystemResource(TestConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
- BROKER_URL = configs.getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
- MESSAGEBOX_URL = configs.getProperty(TestConfigKeys.MSGBOX_SERVICE_EPR);
- consumerPort = Integer.parseInt(configs.getProperty(TestConfigKeys.CONSUMER_PORT));
- // AXIS_REPO=configs.getProperty(TestConfigKeys.AXIS2_REPO);
-
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- @Test
- public void testRenewSubscriptionTest() throws Exception {
-
- String brokerPublishEPR = null;
-
- sub = LeadNotificationManager
- .createMessageBoxSubscription(MESSAGEBOX_URL, BROKER_URL, TOPIC, null, this, false);
-
- brokerPublishEPR = sub.getBrokerURL();
- System.out.println(brokerPublishEPR);
-
- WseMsgBrokerClient client = new WseMsgBrokerClient();
- client.init(brokerPublishEPR);
-
- OMElement msg = OMAbstractFactory.getOMFactory().createOMElement("testMessage", null);
- msg.setText("some message");
- client.publish(TOPIC, msg);
-
- Thread.sleep(10000);
- for (int i = 0; i < messages; ++i) {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- try {
- sub = LeadNotificationManager.renewMessageboxSubscription(BROKER_URL, sub.getMessageBoxEPR(),
- sub.getSubscriptionID(), TOPIC, null, false);
- } catch (AxisFault e) {
- e.printStackTrace();
- }
- }
-
- Thread.sleep(10000);
-
- for (int i = 0; i < messages; ++i) {
- client.publish(TOPIC, msg);
-
- Thread.sleep(100);
-
- }
-
- while (true) {
-
- Thread.sleep(1000);
-
- }
- }
-
- public void deliverMessage(String topic, NotificationType notificationType, XmlObject messageObj) {
- System.out.println(messageObj.toString());
- System.out.println("A message received by handler correctly");
- synchronized (mutex) {
- count++;
- }
- if (count == messages + 1) {
- try {
- sub.destroy();
- } catch (RemoteException e1) {
- e1.printStackTrace();
- }
- System.out.println("Destroyed");
- WseMsgBrokerClient client = new WseMsgBrokerClient();
- client.init(BROKER_URL);
- try {
- client.publish(TOPIC, "some message");
- } catch (MsgBrokerClientException e) {
- e.printStackTrace();
- }
- }
-
- System.out.println(count + " <=" + (messages + 1));
-
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/ThreadMessagePassingCallback.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/ThreadMessagePassingCallback.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/ThreadMessagePassingCallback.java
deleted file mode 100644
index 63c201a..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/ThreadMessagePassingCallback.java
+++ /dev/null
@@ -1,27 +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.test.suite.workflowtracking.tests;
-
-public interface ThreadMessagePassingCallback {
-
- public void done();
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/impl/publish/Test.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/impl/publish/Test.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/impl/publish/Test.java
deleted file mode 100644
index 46c5941..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/impl/publish/Test.java
+++ /dev/null
@@ -1,40 +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.test.suite.workflowtracking.tests.impl.publish;
-
-import org.apache.airavata.workflow.tracking.types.BaseNotificationType;
-import org.apache.airavata.workflow.tracking.types.WorkflowInitializedDocument;
-import org.apache.xmlbeans.XmlCursor;
-
-public class Test {
- public static void main(String[] args) {
- WorkflowInitializedDocument activity = WorkflowInitializedDocument.Factory.newInstance();
- BaseNotificationType activityType = activity.addNewWorkflowInitialized();
-
- XmlCursor c = activity.newCursor();
- c.toNextToken();
-
- System.out.println(c.getObject().getClass());
-
- System.out.println(((BaseNotificationType) c.getObject()).getDescription());
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/impl/publish/TestWSMPublisher.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/impl/publish/TestWSMPublisher.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/impl/publish/TestWSMPublisher.java
deleted file mode 100644
index c676d2e..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/impl/publish/TestWSMPublisher.java
+++ /dev/null
@@ -1,119 +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.test.suite.workflowtracking.tests.impl.publish;
-
-import java.io.IOException;
-
-import org.apache.airavata.workflow.tracking.impl.publish.WSMPublisher;
-import org.apache.axis2.addressing.EndpointReference;
-import org.junit.*;
-
-public class TestWSMPublisher {
-
- @Before
- public void setUp() throws Exception {
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- @org.junit.Test
- public final void testWSMPublisherConstructor1() {
-
- EndpointReference brokerEpr = new EndpointReference("http://invalid/broker/address");
- WSMPublisher publisher = new WSMPublisher(10, false, brokerEpr);
-
- }
-
- @org.junit.Test
- public final void testWSMPublisherConstructor2() {
-
- try {
- WSMPublisher publisher = new WSMPublisher(10, false, "http://invalid/broker/address", "TestTopic1");
-
- } catch (IOException e) {
- // fail("Test failed");
- }
-
- }
-
- @org.junit.Test
- public final void testWSMPublisherConstructor3() {
- try {
-
- EndpointReference epr = new EndpointReference("http://invalid/broker/address");
-
- WSMPublisher publisher = new WSMPublisher(10, false, epr.getAddress());
-
- } catch (Exception e) {
- e.printStackTrace();
- // fail();
- }
- }
-
- @org.junit.Test
- public final void testWSMPublisherConstructor4() {
- try {
-
- EndpointReference epr = new EndpointReference("http://invalid/broker/address");
-
- // According to addressing format.
- String eprFormat = "<BrokerEPR><wsa:Address xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">%s</wsa:Address></BrokerEPR>";
-
- String str = String.format(eprFormat, "http://invalid/broker/address");
-
- WSMPublisher publisher = new WSMPublisher(10, false, str, true);
-
- } catch (Exception e) {
- e.printStackTrace();
- // fail();
- }
- }
-
- @org.junit.Test
- public final void testWSMPublisherConstructor5() {
- // try {
- //
- // EndpointReference epr = new EndpointReference(
- // "http://invalid/broker/address");
- //
- // AnnotationProps annotationProps = AnnotationProps.newProps(
- // AnnotationConsts.ExperimentID, "TestexperId1");
- // annotationProps.set(AnnotationConsts.ServiceLocation,
- // "testServiceAddress");
- //
- // ConstructorProps props = ConstructorProps.newProps();
- // props.set(ConstructorConsts.BROKER_EPR, epr.getAddress());
- // props.set(ConstructorConsts.ENABLE_ASYNC_PUBLISH, "false");
- // props.set(ConstructorConsts.ENABLE_BATCH_PROVENANCE, "false");
- // props.set(ConstructorConsts.ANNOTATIONS, annotationProps);
- //
- // Notifier notifier = NotifierFactory.createGenericNotifier();
- //
- // } catch (Exception e) {
- // e.printStackTrace();
- // fail();
- // }
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/MessagePullerTest.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/MessagePullerTest.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/MessagePullerTest.java
deleted file mode 100644
index 8b9f5f1..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/MessagePullerTest.java
+++ /dev/null
@@ -1,140 +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.test.suite.workflowtracking.tests.messagebox;
-
-import java.io.StringReader;
-import java.net.URL;
-import java.util.Properties;
-import java.util.UUID;
-
-import org.apache.airavata.commons.WorkFlowUtils;
-import org.apache.airavata.workflow.tracking.client.Callback;
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.CommonUtils;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.TestConfigKeys;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.axiom.om.OMElement;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.xmlbeans.XmlObject;
-import org.apache.xmlbeans.impl.tool.XSTCTester.TestCase;
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class MessagePullerTest extends TestCase {
-
- private static final Logger logger = LoggerFactory.getLogger(MessagePullerTest.class);
- static Properties configs = new Properties();
- String BROKER_URL;
- String MESSAGEBOX_URL;
- int consumerPort;
- public static final String TEST_TOPIC = "3a9c7b20-0475-11db-ba88-b61b57d3be03";
- private static final String MESSAGE_BOX_ID = UUID.randomUUID().toString();
- public static int count = 0;
- public int messages = 10;
- public static Object mutex = new Object();
-
- Subscription sub;
- String AXIS_REPO;
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
-
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- URL configURL = ClassLoader.getSystemResource(TestConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
- BROKER_URL = configs.getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
- MESSAGEBOX_URL = configs.getProperty(TestConfigKeys.MSGBOX_SERVICE_EPR);
- consumerPort = Integer.parseInt(configs.getProperty(TestConfigKeys.CONSUMER_PORT));
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- private boolean wait = true;
-
- public void testMessagePulling() throws Exception {
- Subscription subscription = null;
-
- Callback testCallback1 = new Callback() {
- public void deliverMessage(String topic, NotificationType type, XmlObject messageObj) {
- System.out.println("Notification Received, notification of type:" + type);
- // assertEquals(type, NotificationType.WorkflowInitialized);
- wait = false;
- }
- };
-
- subscription = LeadNotificationManager.createMessageBoxSubscription(MESSAGEBOX_URL, BROKER_URL, TEST_TOPIC,
- null, testCallback1);
-
- System.out.println(subscription.getMessageBoxEPR());
- System.out.println(subscription.getSubscriptionID());
-
- WseMsgBrokerClient client = new WseMsgBrokerClient();
- client.init(BROKER_URL);
-
- OMElement msg = WorkFlowUtils.reader2OMElement(new StringReader(CommonUtils.WORKFLOW_INITIALIZED_NOTIFICATION));
-
- client.publish(TEST_TOPIC, msg);
-
- EndpointReference MSG_BOX_EPR = subscription.getMessageBoxEPR();
- System.out.println(MSG_BOX_EPR);
- String subscriptionID = subscription.getSubscriptionID();
- Callback testCallback2 = new Callback() {
-
- public void deliverMessage(String topic, NotificationType type, XmlObject messageObj) {
-
- System.out.println("Notification Received, notification of type:" + type);
- // This assertion is wrong because type and NotificationType.WorkflowInitialized are two different types
- // assertEquals(type, NotificationType.WorkflowInitialized);
- wait = false;
-
- }
- };
- subscription = LeadNotificationManager.startListeningToSavedSubscription(BROKER_URL, MSG_BOX_EPR,
- subscriptionID, TEST_TOPIC, null, testCallback2, true);
-
- System.out.println(subscription.getMessageBoxEPR());
-
- while (wait) {
-
- Thread.sleep(1000);
-
- }
-
- System.out.println("MessagePuller test completed");
- subscription.destroy();
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/MultipleSubscriptionForMessageBoxTest.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/MultipleSubscriptionForMessageBoxTest.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/MultipleSubscriptionForMessageBoxTest.java
deleted file mode 100644
index 4357bef..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/MultipleSubscriptionForMessageBoxTest.java
+++ /dev/null
@@ -1,118 +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.test.suite.workflowtracking.tests.messagebox;
-
-import java.io.StringReader;
-import java.net.URL;
-import java.util.Properties;
-
-import org.apache.airavata.commons.WorkFlowUtils;
-import org.apache.airavata.test.suite.workflowtracking.tests.ThreadMessagePassingCallback;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.CommonUtils;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.TestConfigKeys;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.axiom.om.OMElement;
-import org.apache.xmlbeans.impl.tool.XSTCTester.TestCase;
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class MultipleSubscriptionForMessageBoxTest extends TestCase implements ThreadMessagePassingCallback {
-
- private static final Logger logger = LoggerFactory.getLogger(MultipleSubscriptionForMessageBoxTest.class);
- static Properties configs = new Properties();
- String BROKER_URL;
- String MESSAGEBOX_URL;
- int consumerPort;
- public static final String TEST_TOPIC = "3a9c7b20-0475-11db-ba88-b61b57d3be03";
- public static final int NOTIFICATIONS_PUBLISHED = 10;
- public static final int NUMBER_OF_SUBSCRIBERS = 1;
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
-
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- URL configURL = ClassLoader.getSystemResource(TestConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
- BROKER_URL = configs.getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
- MESSAGEBOX_URL = configs.getProperty(TestConfigKeys.MSGBOX_SERVICE_EPR);
- consumerPort = Integer.parseInt(configs.getProperty(TestConfigKeys.CONSUMER_PORT));
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- private int succesfulclients = 0;
-
- @Test
- public void testMultipleSubscribers() throws Exception {
-
- SubscriberThread[] subscribers = new SubscriberThread[NUMBER_OF_SUBSCRIBERS];
- for (int i = 0; i < NUMBER_OF_SUBSCRIBERS; ++i) {
- subscribers[i] = new SubscriberThread(MESSAGEBOX_URL, BROKER_URL, TEST_TOPIC, this, "MytestId331234"
- + Integer.toString(i));
- subscribers[i].start();
-
- }
-
- Thread.sleep(100);
-
- WseMsgBrokerClient client = new WseMsgBrokerClient();
- client.init(BROKER_URL);
-
- OMElement msg = WorkFlowUtils.reader2OMElement(new StringReader(CommonUtils.WORKFLOW_INITIALIZED_NOTIFICATION));
-
- for (int j = 0; j < NUMBER_OF_SUBSCRIBERS; j++) {
- for (int i = 0; i < NOTIFICATIONS_PUBLISHED; i++) {
-
- client.publish(TEST_TOPIC, msg);
-
- Thread.sleep(100);
- }
- }
-
- while (succesfulclients < NUMBER_OF_SUBSCRIBERS - 1) {
- Thread.sleep(1000);
- }
- Thread.sleep(5000);
- System.out.println("All successful");
- System.exit(0);
-
- }
-
- public void done() {
- succesfulclients++;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/RenewSubscriptionTest.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/RenewSubscriptionTest.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/RenewSubscriptionTest.java
deleted file mode 100644
index 73ef018..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/RenewSubscriptionTest.java
+++ /dev/null
@@ -1,109 +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.test.suite.workflowtracking.tests.messagebox;
-
-import java.net.URL;
-import java.util.Properties;
-
-import org.apache.airavata.workflow.tracking.client.Callback;
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.TestConfigKeys;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.xmlbeans.XmlObject;
-import org.apache.xmlbeans.impl.tool.XSTCTester.TestCase;
-import org.junit.*;
-
-public class RenewSubscriptionTest extends TestCase implements Callback {
-
- static Properties configs = new Properties();
- String BROKER_URL;
- String MESSAGEBOX_URL;
- int consumerPort;
- public static final String TEST_TOPIC = "3a9c7b20-0475-11db-ba88-b61b57d3be03";
- public static int count = 0;
- public int messages = 10;
- public static Object mutex = new Object();
- Subscription sub;
- private static String TOPIC = "RENEW_TOPIC" + Math.random();
- private static int counter = 0;
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
-
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- URL configURL = ClassLoader.getSystemResource(TestConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
- BROKER_URL = configs.getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
- MESSAGEBOX_URL = configs.getProperty(TestConfigKeys.MSGBOX_SERVICE_EPR);
- consumerPort = Integer.parseInt(configs.getProperty(TestConfigKeys.CONSUMER_PORT));
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- @Test
- public void testRenewSubscription() throws Exception {
- Subscription sub = LeadNotificationManager.createMessageBoxSubscription(MESSAGEBOX_URL, BROKER_URL, TOPIC,
- null, this, false);
-
- WseMsgBrokerClient client = new WseMsgBrokerClient();
- client.init(BROKER_URL);
-
- OMElement msg = OMAbstractFactory.getOMFactory().createOMElement("test", null);
- msg.setText("mustwork");
- client.publish(TOPIC, msg);
- // sub.destroy();
-
- msg.setText("destroyed");
- client.publish(TOPIC, msg);
- Subscription sub2 = LeadNotificationManager.renewMessageboxSubscription(BROKER_URL, sub.getMessageBoxEPR(),
- sub.getSubscriptionID(), TOPIC, null, false);
-
- msg.setText("mustworkagain");
- client.publish(TOPIC, msg);
-
- System.out.println(sub2.getSubscriptionID());
- while (counter < 2) {
- Thread.sleep(1000);
- }
- Thread.sleep(10000);
- }
-
- public void deliverMessage(String topic, NotificationType notificationType, XmlObject messageObj) {
- System.out.println("Callbacked");
- System.out.println(messageObj.toString());
- counter++;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/SubscriberThread.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/SubscriberThread.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/SubscriberThread.java
deleted file mode 100644
index c4f58ef..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/SubscriberThread.java
+++ /dev/null
@@ -1,96 +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.test.suite.workflowtracking.tests.messagebox;
-
-import java.rmi.RemoteException;
-
-import org.apache.airavata.workflow.tracking.client.Callback;
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.airavata.test.suite.workflowtracking.tests.ThreadMessagePassingCallback;
-import org.apache.xmlbeans.XmlObject;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class SubscriberThread extends Thread {
-
- private static final Logger logger = LoggerFactory.getLogger(SubscriberThread.class);
- private ThreadMessagePassingCallback callback;
-
- private int subCount = 0;
- private Subscription subscription;
- private String brokerURL;
- private String topic;
- private String messageboxUrl;
- private String msgBoxId;
-
- public SubscriberThread(String messageboxUrl, String brokerURL, String topic,
- ThreadMessagePassingCallback callback, String msgBoxId) {
- super();
- this.msgBoxId = msgBoxId;
- this.callback = callback;
- this.brokerURL = brokerURL;
- this.topic = topic;
- this.messageboxUrl = messageboxUrl;
- }
-
- @Override
- public void run() {
- try {
- subscription = LeadNotificationManager.createMessageBoxSubscription(messageboxUrl, brokerURL, topic, null,
- new Callback() {
-
- public void deliverMessage(String topic, NotificationType type, XmlObject messageObj) {
-
- subCount++;
- System.out.println("Subscription received " + subCount + "th notification of type:" + type);
- assert (type == NotificationType.WorkflowInitialized);
- System.out.println("subcount=" + subCount + " =="
- + MultipleSubscriptionForMessageBoxTest.NOTIFICATIONS_PUBLISHED);
- if (subCount == MultipleSubscriptionForMessageBoxTest.NOTIFICATIONS_PUBLISHED) {
- System.out.println("subscription destroyed");
- try {
- subscription.destroy();
- } catch (RemoteException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- callback.done();
- }
- }
- }, true);
- } catch (Exception e) {
- logger.error("exception in suscriber thread :" + e);
- e.printStackTrace();
- }
- while (true) {
- try {
- Thread.sleep(10000);
- } catch (InterruptedException e) {
- logger.error("exception in suscriber thread sleep: " + e);
- e.printStackTrace();
- }
- }
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/restart/MessageBoxClientRestartTest.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/restart/MessageBoxClientRestartTest.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/restart/MessageBoxClientRestartTest.java
deleted file mode 100644
index e6d1eff..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/restart/MessageBoxClientRestartTest.java
+++ /dev/null
@@ -1,131 +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.test.suite.workflowtracking.tests.messagebox.restart;
-
-import java.io.StringReader;
-import java.net.URL;
-import java.util.Properties;
-
-import org.apache.airavata.commons.WorkFlowUtils;
-import org.apache.airavata.workflow.tracking.client.Callback;
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.CommonUtils;
-import org.apache.airavata.test.suite.workflowtracking.tests.util.TestConfigKeys;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.axiom.om.OMElement;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.xmlbeans.XmlObject;
-import org.apache.xmlbeans.impl.tool.XSTCTester.TestCase;
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class MessageBoxClientRestartTest extends TestCase {
-
- private static final Logger logger = LoggerFactory.getLogger(MessageBoxClientRestartTest.class);
- private static final String TOPIC = "RestartclientTopic2";
- private boolean wait = true;
- static Properties configs = new Properties();
- String BROKER_URL;
- String MESSAGEBOX_URL;
- int consumerPort;
- public static final int NOTIFICATIONS_PUBLISHED = 4;
- public static final int NUMBER_OF_SUBSCRIBERS = 4;
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
-
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- URL configURL = ClassLoader.getSystemResource(TestConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
- BROKER_URL = configs.getProperty(TestConfigKeys.BROKER_EVENTING_SERVICE_EPR);
- MESSAGEBOX_URL = configs.getProperty(TestConfigKeys.MSGBOX_SERVICE_EPR);
- consumerPort = Integer.parseInt(configs.getProperty(TestConfigKeys.CONSUMER_PORT));
-
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- @Test
- public void testRestart() throws Exception {
- Subscription subscription = null;
-
- MessageBoxCreateThread thread = new MessageBoxCreateThread(BROKER_URL, MESSAGEBOX_URL, TOPIC);
- thread.start();
-
- Thread.sleep(100);
- thread.stop();
-
- Thread.sleep(5000);
-
- System.out.println("bringing down the Puller\n Publishing Messages");
- WseMsgBrokerClient client = new WseMsgBrokerClient();
- client.init(BROKER_URL);
-
- OMElement msg = WorkFlowUtils.reader2OMElement(new StringReader(CommonUtils.WORKFLOW_INITIALIZED_NOTIFICATION));
-
- client.publish(TOPIC, msg);
-
- System.out.println("Messages published");
- System.out.println("Creating another puller");
- EndpointReference epr = thread.getWsaEndpointReference();
- String subscriptionID = thread.getSubscriptionID();
- String topic = thread.getTopic();
- System.out.println(epr);
- System.out.println(subscriptionID);
-
- subscription = LeadNotificationManager.startListeningToSavedSubscription(BROKER_URL, epr, subscriptionID,
- topic, null, new Callback() {
-
- public void deliverMessage(String topic, NotificationType type, XmlObject messageObj) {
-
- System.out.println("Notification Received, notification of type:" + type);
- System.out.println("Topic[" + topic + "]");
- // assertEquals(type, NotificationType.WorkflowInitialized);
- wait = false;
-
- }
- }, false);
-
- System.out.println(subscription.getMessageBoxEPR());
-
- while (wait) {
- Thread.sleep(1000);
-
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/restart/MessageBoxCreateThread.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/restart/MessageBoxCreateThread.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/restart/MessageBoxCreateThread.java
deleted file mode 100644
index 5ea8278..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/messagebox/restart/MessageBoxCreateThread.java
+++ /dev/null
@@ -1,83 +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.test.suite.workflowtracking.tests.messagebox.restart;
-
-import org.apache.airavata.workflow.tracking.client.Callback;
-import org.apache.airavata.workflow.tracking.client.LeadNotificationManager;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.client.Subscription;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.xmlbeans.XmlObject;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class MessageBoxCreateThread extends Thread {
-
- private static final Logger logger = LoggerFactory.getLogger(MessageBoxCreateThread.class);
- private String brokerLocation;
- private String messageboxLocation;
- private String topic;
- private Subscription subscription;
-
- public MessageBoxCreateThread(String brokerLocation, String messageboxLocation, String topic) {
- super();
- this.brokerLocation = brokerLocation;
- this.messageboxLocation = messageboxLocation;
- this.topic = topic;
-
- }
-
- @Override
- public void run() {
- Subscription subscription = null;
- try {
- subscription = LeadNotificationManager.createMessageBoxSubscription(this.messageboxLocation,
- this.brokerLocation, this.topic, null, new Callback() {
-
- public void deliverMessage(String topic, NotificationType type, XmlObject messageObj) {
-
- throw new RuntimeException("This piece of code probably shouldnt have been called");
-
- }
- }, true);
-
- System.out.println("Created messageBox");
- } catch (Exception e1) {
- logger.error("error in message box creat thread :" + e1);
- e1.printStackTrace();
- }
- this.subscription = subscription;
- }
-
- public String getSubscriptionID() {
- return this.subscription.getSubscriptionID();
- }
-
- public EndpointReference getWsaEndpointReference() {
- return this.subscription.getMessageBoxEPR();
- }
-
- public String getTopic() {
- return this.subscription.getTopic();
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/66de3728/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/SimpleTest.java
----------------------------------------------------------------------
diff --git a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/SimpleTest.java b/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/SimpleTest.java
deleted file mode 100644
index db7d915..0000000
--- a/modules/test-suite/src/test/java/org/apache/airavata/test/suite/workflowtracking/tests/samples/workflow/SimpleTest.java
+++ /dev/null
@@ -1,202 +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.test.suite.workflowtracking.tests.samples.workflow;
-
-/**
- * Simple test that generates notifications from the perspective of an application (e.g. Jython script or web service)
- * or a Workflow engine. The following 1 service workflow is simulated:
- *
- * <pre>
- * ................ ________
- * ........001 --->| |---> XXXX
- * ................| FuBar1 |
- * ........002 --->|________|---> YYYY
- * </pre>
- *
- */
-public class SimpleTest {
-
- // public static long runWorkflowEngine(Notifier notifier, int count) throws Exception {
- //
- // Timer t = Timer.initAndStart("wfEngine");
- // for (int i=0; i < count; i++) {
- //
- // // start running the workflow
- // notifier.workflowInvoked(
- // // optional input param names to workflow
- // new String[]{"dataFileID", "confFileURL"},
- // // optional input param values to workflow
- // new String[]{"leadId:dgk8634yas", "gridftp://tempuri.org/conf.txt"}
- // );
- //
- // // start to invoke a service
- // ServiceObj svcObj =
- // notifier.invokeServiceStarted(
- // // optional input param names to service
- // new String[]{"dataFileID", "confFileURL"},
- // // optional input param values to service
- // new String[]{"leadId:dgk8634yas", "gridftp://tempuri.org/conf.txt"},
- // "Node1", // node ID in workflow
- // "step1", // timestep in workflow execution
- // "{http://foobar.org}FuBar1" // Servce QName
- // );
- //
- // // invocation returned successfully
- // notifier.serviceFinishedSuccess(svcObj);
- //
- // // OR invocation failed
- // // notifier.serviceFinishedFailed(svcObj, "service failed");
- //
- // // workflow completed successfully
- // notifier.workflowFinishedSuccess();
- //
- // // OR workflow failed
- // // notifier.workflowFinishedFailed("i failed!");
- //
- // // Done with workflow. call flush to ensure messages are sent...
- // notifier.flush();
- // }
- //
- // return t.end("done: " + count);
- // }
- //
- // public static long runService(Notifier notifier, int count) throws Exception {
- //
- // String done = "done " + count;
- // Timer t = Timer.initAndStart("service"); // start timer
- // for (int i=0; i < count; i++) {
- //
- // // APP STARTS
- // notifier.serviceInvoked("FuBarApp1"); // we can optionally pass the input params & values too
- //
- // // START TO RECEIVE A FILE
- // DataObj fileObj =
- // notifier.fileReceiveStarted("leadId-001", // leadID
- // "gridftp://remotehost.org/foo.dat", // remote file source
- // "/data/tmp/foo.dat"); // local file destination
- // /* APP DOES FILE TRANSFER ... */
- // // DONE RECEIVING FILE
- // notifier.fileReceiveFinished(fileObj);
- //
- // // THE RECEIVED FILE WILL BE CONSUMED IN A COMPUTATION
- // // ALONG WITH ANOTHER LOCAL FILE
- // notifier.dataConsumed(fileObj);
- // notifier.dataConsumed("leadId-002", "/etc/app/config/foo.cfg");
- //
- // // send info message on some processing
- // int runs = 2;
- // notifier.info("i'm going to use input file for " + runs + " number of WRF runs ...");
- //
- // // START COMPUTATION RUNS
- // for (int j=0; j < runs; j++) {
- // // START COMPUTATION
- // DurationObj compObj = notifier.computationStarted("WRF Run");
- // /* APP DOES COMPUTATION ... */
- // // FINISHED COMPUTATION
- // notifier.computationFinished(compObj);
- // }
- //
- // // NOTIFY THAT A FILE WAS PRODUCED
- // DataObj fileObj2 = notifier.fileProduced("/data/tmp/output/bar.dat");
- //
- // // START SENDING OUTPUT FILE TO REMOTE LOCATION
- // notifier.fileSendStarted(fileObj2, "gridftp://remotehost.org/bar.dat");
- // /* APP DOES FILE TRANSFER ... */
- // // DONE SENDING FILE
- // notifier.fileSendFinished(fileObj2);
- //
- // // PUBLISH THE OUTPUT FILE URL AS MESSAGE FOR VIZ
- // notifier.publishURL("Output visualization", "http://localhost/" + fileObj2.getLocalLocation());
- //
- // // APPLICATION COMPLETES
- // notifier.sendingResult(null, null);
- //
- // // DONE SENDING NOTIFICATIONS. CALL FLUSH TO ENSURE ALL MESSAGES HAVE BEEN PUBLISHED...
- // notifier.flush();
- // }
- // return t.end(done); // end timer
- //
- // }
- //
- // public static void main(String[] args) throws Exception {
- //
- // System.out.println("USAGE: java SimpleTest [service | engine] <iterations>");
- //
- // boolean runAsEngine = "engine".equalsIgnoreCase(args[0]); // run test as if from workflow engine
- // boolean runAsService = "service".equalsIgnoreCase(args[0]); // run test as if from application service
- // if (!runAsEngine && !runAsService) {
- // throw new Exception("pass either 'service' or 'engine' as param");
- // }
- //
- //
- // int count = 1;
- // try {
- // count = Integer.parseInt(args[1]);
- // } catch (NumberFormatException e) {
- // // ignore and use count = 1
- // }
- //
- // System.out.println("Running as : " + (runAsEngine ? "ENGINE" : "SERVICE") +
- // " for " + count + " iterations");
- //
- // // create the properties constructor...see CONSTS.java for more options
- // // Passing System.getProperties() ensures that any system properties that are set are
- // // carried over into the constructor
- // Props props =
- // //Props.newProps(System.getProperties()).
- // Props.newProps("properties.xml").
- // set(CONSTS.WORKFLOW_ID, "wf100201").
- // set(CONSTS.ENABLE_NAME_RESOLVER, "false").
- // // set(NAME_RESOLVER_URL, ""). // since name resolver is disabled, we do not need URL
- // //set(IN_XML_MESSAGE, ""). // pass the incoming SOAP message if async response to sender required
- // set(CONSTS.BROKER_URL, "rainier.extreme.indiana.edu:12346").
- // set(CONSTS.TOPIC, "somerandomtopic");
- //
- // // when running from the service perspective, additional attributes are need
- // // ...not needed when running as workflow engine
- // if (runAsService) {
- // props.
- // /* either this service's QName should be passed as SERVICE_ID or */
- // /* its WSDL should be passed as SERVICE_WSDL to extract its QName */
- // set(CONSTS.SERVICE_ID, "{http://foobar.org}FuBar1").
- // //set(CONSTS.SERVICE_WSDL, "<wsdl:definitions/>").
- // set(CONSTS.NODE_ID, "N1").
- // set(CONSTS.TIMESTEP, "1");
- // }
- //
- // // creates the default notifier and passes above properties to it as parameters
- // Notifier notifier = NotifierFactory.createNotifier(props);
- //
- // long time = -1;
- // if (runAsService) {
- // time = runService(notifier, count);
- //
- // }
- //
- // if (runAsEngine) {
- // time = runWorkflowEngine(notifier, count);
- // }
- //
- // System.out.println("Done in " + time + " millis");
- // }
-}
-