airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sma...@apache.org
Subject [2/2] airavata git commit: Removing the stale WS Messenger - AIRAVATA-1556
Date Thu, 05 Mar 2015 18:59:59 GMT
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 <smarru@apache.org>
Authored: Thu Mar 5 13:56:09 2015 -0500
Committer: Suresh Marru <smarru@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");
-    // }
-}
-


Mime
View raw message