airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject [14/53] [abbrv] airavata git commit: retiring ws-messenger and remove dependency of workflow tracking - AIRAVATA-1556, AIRAVATA-1557
Date Fri, 06 Feb 2015 16:05:27 GMT
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/commons/TestCommonRoutines.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/commons/TestCommonRoutines.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/commons/TestCommonRoutines.java
deleted file mode 100644
index 098dd49..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/commons/TestCommonRoutines.java
+++ /dev/null
@@ -1,57 +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.wsmg.commons;
-
-import java.util.Date;
-
-import junit.framework.TestCase;
-
-import org.apache.airavata.wsmg.commons.CommonRoutines;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-public class TestCommonRoutines extends TestCase {
-
-    /**
-     * @throws java.lang.Exception
-     */
-    @Before
-    public void setUp() throws Exception {
-    }
-
-    /**
-     * @throws java.lang.Exception
-     */
-    @After
-    public void tearDown() throws Exception {
-    }
-
-    /**
-     * Test method for {@link org.apache.airavata.wsmg.commons.CommonRoutines#getXsdDateTime(java.util.Date)}.
-     */
-    @Test
-    public void testGetXsdDateTime() {
-        assertNotNull(CommonRoutines.getXsdDateTime(new Date()));
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestAddtionalWseXpathAndTopicScenarios.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestAddtionalWseXpathAndTopicScenarios.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestAddtionalWseXpathAndTopicScenarios.java
deleted file mode 100644
index 6f1ecbb..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestAddtionalWseXpathAndTopicScenarios.java
+++ /dev/null
@@ -1,151 +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.wsmg.matching.XPath;
-
-import java.net.URL;
-import java.util.Properties;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
-
-import javax.xml.stream.XMLStreamException;
-
-import junit.framework.TestCase;
-
-import org.apache.airavata.wsmg.client.ConsumerNotificationHandler;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.airavata.wsmg.util.ConfigKeys;
-import org.apache.airavata.wsmg.util.TestUtilServer;
-import org.apache.axiom.om.impl.llom.util.AXIOMUtil;
-import org.apache.axiom.soap.SOAPEnvelope;
-import org.apache.axis2.AxisFault;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-public class TestAddtionalWseXpathAndTopicScenarios extends TestCase {
-
-    static Properties configs = new Properties();
-
-    class NotificationReciever implements ConsumerNotificationHandler {
-
-        private BlockingQueue<SOAPEnvelope> queue = new LinkedBlockingQueue<SOAPEnvelope>();
-
-        private String id;
-
-        public NotificationReciever(String id) {
-            this.id = id;
-        }
-
-        public void handleNotification(SOAPEnvelope msgEnvelope) {
-            queue.add(msgEnvelope);
-            System.out.println(String.format("[reciever id: %s] %s", id, msgEnvelope));
-        }
-
-        public BlockingQueue<SOAPEnvelope> getMsgQueue() {
-            return queue;
-        }
-    }
-
-    @Before
-    public void setUp() throws Exception {
-        URL configURL = ClassLoader.getSystemResource(ConfigKeys.CONFIG_FILE_NAME);
-        configs.load(configURL.openStream());
-
-        TestUtilServer.start(null, null);
-    }
-
-    @After
-    public void tearDown() throws Exception {
-    }
-
-    @Test
-    public final void testXpathAndTopicOnlyRoundTrip() {
-
-        try {
-
-            String topic = "RoundTripTestXpathAndTopicWse";
-
-            String xpathExpression = "/c/b/a[text()=1]";
-
-            String msgFormat = "<c><b><a>%d</a></b></c>";
-
-            long value = 1;
-            String matchingMsg = String.format(msgFormat, value);
-            String unmatchingMsg = String.format(msgFormat, value + 1);
-
-            int consumerPort = TestUtilServer.getAvailablePort();
-
-            String brokerEpr = "http://localhost:" + TestUtilServer.TESTING_PORT + "/axis2/services/EventingService";
-
-            WseMsgBrokerClient topicOnlyReceiverApi = new WseMsgBrokerClient();
-            topicOnlyReceiverApi.init(brokerEpr);
-            NotificationReciever topicOnlyMsgReceiver = new NotificationReciever("Topic Only");
-            String[] topicConsumerEPRs = topicOnlyReceiverApi.startConsumerService(consumerPort, topicOnlyMsgReceiver);
-            assertTrue("invalid consumer eprs returned", topicConsumerEPRs.length > 0);
-            String topicOnlySubId = topicOnlyReceiverApi.subscribe(topicConsumerEPRs[0], topic, null);
-            System.out.println("Topic only subscription ID: " + topicOnlySubId);
-
-            WseMsgBrokerClient xpathAndTopicReceiverApi = new WseMsgBrokerClient();
-            xpathAndTopicReceiverApi.init(brokerEpr);
-            NotificationReciever topicAndXpathMsgReceiver = new NotificationReciever("Topic And Xpath");
-            String[] topicAndXpathConsumerEPRs = xpathAndTopicReceiverApi.startConsumerService(consumerPort + 1,
-                    topicAndXpathMsgReceiver);
-            assertTrue("invalid consumer eprs returned", topicAndXpathConsumerEPRs.length > 0);
-            String topicAndXpathSubId = xpathAndTopicReceiverApi.subscribe(topicAndXpathConsumerEPRs[0], topic,
-                    xpathExpression);
-            System.out.println("Xpath and Topic subscription ID: " + topicAndXpathSubId);
-
-            WseMsgBrokerClient senderApi = new WseMsgBrokerClient();
-            senderApi.init(brokerEpr);
-
-            try {
-
-                senderApi.publish(topic, AXIOMUtil.stringToOM(matchingMsg));
-                senderApi.publish(topic, AXIOMUtil.stringToOM(unmatchingMsg));
-
-                Thread.sleep(5000);
-
-                assertTrue("topic only reciever should get all messages" + topicOnlyMsgReceiver.getMsgQueue().size(),
-                        topicOnlyMsgReceiver.getMsgQueue().size() == 2);
-
-                assertTrue("xpath and topic reciever should only get one message"
-                        + topicAndXpathMsgReceiver.getMsgQueue().size(),
-                        topicAndXpathMsgReceiver.getMsgQueue().size() == 1);
-            } catch (XMLStreamException x) {
-                fail("Error while creating OMElement");
-            } catch (InterruptedException e) {
-                fail("interrupted while waiting for message");
-            }
-
-            topicOnlyReceiverApi.unSubscribe(topicOnlySubId);
-            topicOnlyReceiverApi.shutdownConsumerService();
-
-            xpathAndTopicReceiverApi.unSubscribe(topicAndXpathSubId);
-            xpathAndTopicReceiverApi.shutdownConsumerService();
-
-        } catch (AxisFault e) {
-            e.printStackTrace();
-            fail("unexpected exception occured");
-        }
-
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestWseXpathAndTopicSubscription.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestWseXpathAndTopicSubscription.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestWseXpathAndTopicSubscription.java
deleted file mode 100644
index 024b5d3..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestWseXpathAndTopicSubscription.java
+++ /dev/null
@@ -1,137 +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.wsmg.matching.XPath;
-
-import java.net.URL;
-import java.util.Properties;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
-
-import javax.xml.stream.XMLStreamException;
-
-import junit.framework.TestCase;
-
-import org.apache.airavata.wsmg.client.ConsumerNotificationHandler;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.airavata.wsmg.util.ConfigKeys;
-import org.apache.airavata.wsmg.util.TestUtilServer;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.impl.llom.util.AXIOMUtil;
-import org.apache.axiom.soap.SOAPEnvelope;
-import org.apache.axis2.AxisFault;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-public class TestWseXpathAndTopicSubscription extends TestCase implements ConsumerNotificationHandler {
-
-    static Properties configs = new Properties();
-
-    BlockingQueue<SOAPEnvelope> queue = new LinkedBlockingQueue<SOAPEnvelope>();
-
-    public void handleNotification(SOAPEnvelope msgEnvelope) {
-
-        queue.add(msgEnvelope);
-        System.out.println(msgEnvelope);
-    }
-
-    BlockingQueue<SOAPEnvelope> getMsgQueue() {
-        return queue;
-    }
-
-    @Before
-    public void setUp() throws Exception {
-        URL configURL = ClassLoader.getSystemResource(ConfigKeys.CONFIG_FILE_NAME);
-        configs.load(configURL.openStream());
-
-        TestUtilServer.start(null, null);
-    }
-
-    @After
-    public void tearDown() throws Exception {
-    }
-
-    @Test
-    public final void testXpathOnlyRoundTrip() {
-
-        try {
-
-            String validMsgFormat = "<c><b><a> %d </a></b></c>";
-            String invalidMsgFormat = "<a><b><c> %d </c></b></a>";
-
-            long value = System.currentTimeMillis();
-            String validMsg = String.format(validMsgFormat, value);
-            String invalidMsg = String.format(invalidMsgFormat, value);
-
-            int consumerPort = TestUtilServer.getAvailablePort();
-
-            String brokerEPR = "http://localhost:" + TestUtilServer.TESTING_PORT + "/axis2/services/EventingService";
-            WseMsgBrokerClient msgBrokerClient = new WseMsgBrokerClient();
-            msgBrokerClient.init(brokerEPR);
-
-            String[] consumerEPRs = msgBrokerClient.startConsumerService(consumerPort, this);
-
-            assertTrue(consumerEPRs.length > 0);
-
-            String xpathExpression = "/c/b/a";
-
-            String subscriptionID = msgBrokerClient.subscribe(consumerEPRs[0], null, xpathExpression);
-
-            try {
-                msgBrokerClient.publish(null, AXIOMUtil.stringToOM(validMsg));
-                msgBrokerClient.publish(null, AXIOMUtil.stringToOM(invalidMsg));
-
-                SOAPEnvelope env = getMsgQueue().take();
-
-                assertNotNull(env.getBody());
-                assertNotNull(env.getBody().getChildrenWithLocalName("c"));
-
-                OMElement element = (OMElement) env.getBody().getChildrenWithLocalName("c").next();
-
-                String text = element.toStringWithConsume();
-
-                assertTrue("round trip of message failed" + " - due to invalid messege content",
-                        text.indexOf(new Long(value).toString()) > 0);
-
-                Thread.sleep(5000);
-
-                assertTrue("unexpected msg recieved", getMsgQueue().isEmpty());
-
-            } catch (InterruptedException e) {
-                fail("interrupted while waiting for message");
-            } catch (XMLStreamException e) {
-                // TODO Auto-generated catch block
-                e.printStackTrace();
-                fail("invalid xml recieved: " + e.getMessage());
-            }
-
-            msgBrokerClient.unSubscribe(subscriptionID);
-            msgBrokerClient.shutdownConsumerService();
-
-        } catch (AxisFault e) {
-            e.printStackTrace();
-            fail("unexpected exception occured");
-        }
-
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestWseXpathSubscription.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestWseXpathSubscription.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestWseXpathSubscription.java
deleted file mode 100644
index 097e6b7..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/TestWseXpathSubscription.java
+++ /dev/null
@@ -1,139 +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.wsmg.matching.XPath;
-
-import java.net.URL;
-import java.util.Properties;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
-
-import javax.xml.stream.XMLStreamException;
-
-import junit.framework.TestCase;
-
-import org.apache.airavata.wsmg.client.ConsumerNotificationHandler;
-import org.apache.airavata.wsmg.client.WseMsgBrokerClient;
-import org.apache.airavata.wsmg.util.ConfigKeys;
-import org.apache.airavata.wsmg.util.TestUtilServer;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.impl.llom.util.AXIOMUtil;
-import org.apache.axiom.soap.SOAPEnvelope;
-import org.apache.axis2.AxisFault;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-public class TestWseXpathSubscription extends TestCase implements ConsumerNotificationHandler {
-
-    static Properties configs = new Properties();
-
-    BlockingQueue<SOAPEnvelope> queue = new LinkedBlockingQueue<SOAPEnvelope>();
-
-    public void handleNotification(SOAPEnvelope msgEnvelope) {
-
-        queue.add(msgEnvelope);
-        System.out.println(msgEnvelope);
-    }
-
-    BlockingQueue<SOAPEnvelope> getMsgQueue() {
-        return queue;
-    }
-
-    @Before
-    public void setUp() throws Exception {
-        URL configURL = ClassLoader.getSystemResource(ConfigKeys.CONFIG_FILE_NAME);
-        configs.load(configURL.openStream());
-
-        TestUtilServer.start(null, null);
-    }
-
-    @After
-    public void tearDown() throws Exception {
-    }
-
-    @Test
-    public final void testSimpleXpathTopicRoundTrip() {
-
-        try {
-
-            String validMsgFormat = "<c><b><a> %d </a></b></c>";
-            String invalidMsgFormat = "<a><b><c> %d </c></b></a>";
-
-            long value = System.currentTimeMillis();
-            String validMsg = String.format(validMsgFormat, value);
-            String invalidMsg = String.format(invalidMsgFormat, value);
-
-            int consumerPort = TestUtilServer.getAvailablePort();
-
-            String brokerEPR = "http://localhost:" + TestUtilServer.TESTING_PORT + "/axis2/services/EventingService";
-
-            WseMsgBrokerClient wseMsgBrokerClient = new WseMsgBrokerClient();
-            wseMsgBrokerClient.init(brokerEPR);
-
-            String[] consumerEPRs = wseMsgBrokerClient.startConsumerService(consumerPort, this);
-
-            assertTrue(consumerEPRs.length > 0);
-
-            String xpathExpression = "/c/b/a";
-            String topicExpression = "XpathAndTopicTestWse";
-
-            String subscriptionID = wseMsgBrokerClient.subscribe(consumerEPRs[0], topicExpression, xpathExpression);
-
-            try {
-
-                wseMsgBrokerClient.publish(topicExpression, AXIOMUtil.stringToOM(validMsg));
-                wseMsgBrokerClient.publish(topicExpression, AXIOMUtil.stringToOM(invalidMsg));
-
-                SOAPEnvelope env = getMsgQueue().take();
-
-                assertNotNull(env.getBody());
-                assertNotNull(env.getBody().getChildrenWithLocalName("c"));
-
-                OMElement element = (OMElement) env.getBody().getChildrenWithLocalName("c").next();
-
-                String text = element.toStringWithConsume();
-
-                assertTrue("round trip of message failed" + " - due to invalid messege content",
-                        text.indexOf(new Long(value).toString()) > 0);
-
-                Thread.sleep(5000);
-
-                assertTrue("unexpected msg recieved", getMsgQueue().isEmpty());
-
-            } catch (InterruptedException e) {
-                fail("interrupted while waiting for message");
-            } catch (XMLStreamException e) {
-                // TODO Auto-generated catch block
-                e.printStackTrace();
-                fail("invalid xml recieved: " + e.getMessage());
-            }
-
-            wseMsgBrokerClient.unSubscribe(subscriptionID);
-            wseMsgBrokerClient.shutdownConsumerService();
-
-        } catch (AxisFault e) {
-            e.printStackTrace();
-            fail("unexpected exception occured");
-        }
-
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/performance/XppXPath.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/performance/XppXPath.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/performance/XppXPath.java
deleted file mode 100644
index da95a00..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/matching/XPath/performance/XppXPath.java
+++ /dev/null
@@ -1,269 +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.wsmg.matching.XPath.performance;
-
-import java.io.BufferedReader;
-import java.io.ByteArrayInputStream;
-import java.io.FileReader;
-import java.io.IOException;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.Set;
-import java.util.StringTokenizer;
-import java.util.Vector;
-
-import javax.xml.namespace.QName;
-import javax.xml.stream.FactoryConfigurationError;
-import javax.xml.stream.XMLInputFactory;
-import javax.xml.stream.XMLStreamException;
-import javax.xml.stream.XMLStreamReader;
-
-import edu.berkeley.cs.db.yfilterplus.queryparser.QueryParser;
-import edu.berkeley.cs.db.yfilterplus.queryparser.XPQueryParser;
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMXMLParserWrapper;
-import org.apache.axiom.om.impl.llom.factory.OMXMLBuilderFactory;
-import org.apache.axiom.soap.SOAPEnvelope;
-
-public class XppXPath {
-
-    private Vector xPathExpressions = new Vector();
-    protected BufferedReader m_in = null;
-    private static final boolean DEBUG = false;
-    long total = 0;
-
-    public int[] getMatchedLinks(String message) {
-
-        return null;
-    }
-
-    public Vector checkQueries(String query) {
-        Vector result = new Vector();
-        Set xPathExpressionsSet = new HashSet(xPathExpressions);
-
-        int size = xPathExpressions.size();
-
-        for (int i = 0; i < size; i++) {
-
-            boolean match = query.equals(xPathExpressions.get(i));
-
-            // long start=System.nanoTime();
-            if (match) {
-
-                result.add(new Integer(i));
-
-            }
-            // long end=System.nanoTime();
-            // total+=(end-start);
-        }
-
-        // System.out.println("Total="+total);
-        return result;
-    }
-
-    public boolean checkQueriesVectorToSet(Set queries) {
-        // Vector result=new Vector();
-        Set xPathExpressionsSet = new HashSet(xPathExpressions);
-
-        int size = xPathExpressions.size();
-        Iterator iter = queries.iterator();
-        int counter = 0;
-        while (iter.hasNext()) {
-            Object query = iter.next();
-            for (int i = 0; i < size; i++) {
-
-                boolean match = query.equals(xPathExpressions.get(i));
-
-                // long start=System.nanoTime();
-                if (match) {
-
-                    return true;
-
-                }
-                // long end=System.nanoTime();
-                // total+=(end-start);
-            }
-            counter++;
-            // System.out.println("counter="+counter);
-        }
-        // System.out.println("Total="+total);
-        return false;
-    }
-
-    public boolean checkQueriesBySet(Set queries) {
-        Set xPathExpressionsSet = new HashSet(xPathExpressions);
-        Iterator iter = queries.iterator();
-        int counter = 0;
-        while (iter.hasNext()) {
-            if (xPathExpressionsSet.contains(iter.next())) {
-                // System.out.println("counter="+counter);
-                return true;
-            }
-            counter++;
-        }
-        return false;
-    }
-
-    public void addXPathExpressions(String xPathExpression) {
-        xPathExpressions.add(xPathExpression);
-    }
-
-    public void readQueriesFromFile(String queryFile) {
-        int noQueries = Integer.MAX_VALUE;
-        int qNum = 0;
-        // QueryParser qp = new XFQueryParser(queryFile);
-        QueryParser qp = new XPQueryParser(queryFile);
-        // Query query;
-        String queryString;
-        while (qNum < noQueries && ((queryString = qp.readNextQueryString()) != null)) {
-            if (DEBUG)
-                System.out.println(queryString);
-            addXPathExpressions(queryString);
-            qNum++;
-        }
-    }
-
-    public String getARandomQuery() {
-        int index = (int) (xPathExpressions.size() * (Math.random()));
-        return (String) xPathExpressions.get(index);
-    }
-
-    // From http://www.rgagnon.com/javadetails/java-0052.html
-    public static String readFile(String filename) throws IOException {
-        String lineSep = System.getProperty("line.separator");
-        BufferedReader br = new BufferedReader(new FileReader(filename));
-        String nextLine = "";
-        StringBuffer sb = new StringBuffer();
-        while ((nextLine = br.readLine()) != null) {
-            sb.append(nextLine);
-            //
-            // note:
-            // BufferedReader strips the EOL character.
-            //
-            sb.append(lineSep);
-        }
-        return sb.toString();
-    }
-
-    /**
-     * @param args
-     * @throws IOException
-     * @throws FactoryConfigurationError
-     * @throws XMLStreamException
-     */
-    public static void main(String[] args) throws IOException, XMLStreamException, FactoryConfigurationError {
-        String queryFile = "C:\\YiFile\\yfilter-1.0\\yfilter-1.0\\queries2.txt";
-        XppXPath xppXPath = new XppXPath();
-        xppXPath.readQueriesFromFile(queryFile);
-        long total = 0;
-        final int round = 100;
-        String message = readFile("c:\\YiFile\\testdata\\soap2.txt");
-
-        int messageStartPoint = message.indexOf('<');
-        String xpathList = message.substring(0, messageStartPoint);
-        System.out.println("XpathList=" + xpathList);
-        System.out.println("*****************************************");
-        long start0 = System.nanoTime();
-        StringTokenizer parser0 = new StringTokenizer(xpathList, ";");
-        Set xpathTokens = new HashSet();
-        while (parser0.hasMoreTokens()) {
-            xpathTokens.add(parser0.nextToken());
-        }
-        long end0 = System.nanoTime();
-        long total0 = (end0 - start0);
-        // for(int i=0;i<xpathTokens.size();i++){
-        // System.out.println((String)xpathTokens.get(i));
-        // }
-        System.out.println("Avg Time to token=" + (total0));
-        System.out.println("Total token=" + xpathTokens.size());
-        boolean result = false;
-        for (int i = 0; i < round; i++) {
-            String randomQuery = xppXPath.getARandomQuery();
-            // xpathTokens.add(randomQuery);
-            // Vector result=null;
-
-            long start = System.nanoTime();
-            // result=xppXPath.checkQueries(randomQuery);
-            result = xppXPath.checkQueriesBySet(xpathTokens);
-            // result=xppXPath.checkQueriesVectorToSet(xpathTokens);
-            long end = System.nanoTime();
-            total += (end - start);
-        }
-        System.out.println("Match result=" + result);
-        System.out.println("Avg Time for Checking=" + (total / round));
-
-        // XSUL
-        // long start=System.nanoTime();
-        // XmlElement messageEl = builder.parseFragmentFromReader(new
-        // StringReader(
-        // message));
-        // XmlElement messageIdEl= messageEl.element(null,
-        // "Header").element(null,"MessageID");
-        // String messageId=messageIdEl.requiredTextContent();
-        // System.out.println("MessageId="+messageId);
-        // long end=System.nanoTime();
-        // total=(end-start);
-        // System.out.println("Avg Time="+(total));
-
-        // AXIOM
-        // long start=System.nanoTime();
-        // create the parser
-        // XMLStreamReader parser =
-        // XMLInputFactory.newInstance().createXMLStreamReader(new
-        // FileReader("c:\\YiFile\\testdata\\soap_only.txt"));
-        // create the builder
-        String message1 = readFile("c:\\YiFile\\testdata\\soap_only.txt");
-        long start = System.nanoTime();
-        XMLStreamReader parser = XMLInputFactory.newInstance().createXMLStreamReader(
-                new ByteArrayInputStream(message1.getBytes()));
-
-        OMXMLParserWrapper builder = OMXMLBuilderFactory.createStAXSOAPModelBuilder(
-                OMAbstractFactory.getSOAP11Factory(), parser);
-        // get the root element (in this case the envelope)
-
-        SOAPEnvelope envelope = (SOAPEnvelope) builder.getDocumentElement();
-
-        // // create the parser
-        // XMLStreamReader parser =
-        // XMLInputFactory.newInstance().createXMLStreamReader(new
-        // FileReader("c:\\YiFile\\testdata\\soap.txt"));
-        // // create the builder
-        // OMXMLParserWrapper builder =
-        // OMXMLBuilderFactory.createStAXSOAPModelBuilder(OMAbstractFactory.getOMFactory(),parser);
-        // // get the root element (in this case the envelope)
-        // SOAPEnvelope envelope = (SOAPEnvelope)builder.getDocumentElement();
-        //
-        //
-        String messageIDString = envelope.getHeader().getFirstChildWithName(new QName(null, "MessageID")).getText();
-        long end = System.nanoTime();
-        total = (end - start);
-        System.out.println("Avg Time for Axiom=" + (total));
-        // OMElement headerEl=envelope.getHeader().getFirstChildWithName(new
-        // QName("http://schemas.xmlsoap.org/soap/envelope/", "Header"));
-        envelope.getHeader().getFirstChildWithName(new QName(null, "MessageID")).serialize(System.out);
-        System.out.println();
-        //
-        // headerEl.getFirstChildWithName(new QName(null, "MessageID"));
-
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/NotificationManager.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/NotificationManager.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/NotificationManager.java
deleted file mode 100644
index c168a5f..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/NotificationManager.java
+++ /dev/null
@@ -1,151 +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.wsmg.performance_evaluator.rtt;
-
-import java.util.LinkedList;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
-
-import org.apache.airavata.wsmg.client.*;
-import org.apache.axiom.soap.SOAPEnvelope;
-
-public class NotificationManager implements ConsumerNotificationHandler {
-
-    private MessageBrokerClient client = null;
-    private String[] eprs = null;
-    private String brokerLocation = null;
-    private String protocol = null;
-    private int consumerServerPort = 0;
-    private LinkedList<String> subscriptionIds;
-    private int numberOfTopicSubscribed = 0;
-    private int numMultiThreadSupportPerSub = 0;
-    private int multipleThreadSupportIndex = 1;
-
-    public NotificationManager(String brokerLocationIn, int consumerServerPortIn, String protocolIn,
-            int numMultiThreadSupportPerSub) throws MsgBrokerClientException {
-
-        this.brokerLocation = brokerLocationIn;
-        this.consumerServerPort = consumerServerPortIn;
-        this.protocol = protocolIn;
-        this.numMultiThreadSupportPerSub = numMultiThreadSupportPerSub;
-
-        if (client == null) {
-            if (protocol.equalsIgnoreCase("wse")) {
-                WsntMsgBrokerClient wseClient = new WsntMsgBrokerClient();
-                wseClient.init(this.brokerLocation);
-                wseClient.setTimeoutInMilliSeconds(200000000);
-                eprs = wseClient.startConsumerService(consumerServerPort, this);
-                client = wseClient;
-            } else {
-                WsntMsgBrokerClient wsntClient = new WsntMsgBrokerClient();
-                wsntClient.init(this.brokerLocation);
-                wsntClient.setTimeoutInMilliSeconds(200000000);
-                eprs = wsntClient.startConsumerService(consumerServerPort, this);
-                client = wsntClient;
-            }
-        }
-
-        subscriptionIds = new LinkedList<String>();
-
-    }
-
-    public Subscription createTopicSubscription(String topic) throws Exception {
-
-        if (multipleThreadSupportIndex > numMultiThreadSupportPerSub) {
-            multipleThreadSupportIndex = 1;
-        }
-
-        String subscriptionId = client
-                .subscribe(brokerLocation, eprs[0] + "user" + multipleThreadSupportIndex++, topic);
-        subscriptionIds.add(subscriptionId);
-        Subscription subscription = new Subscription(client, subscriptionId, topic, this, brokerLocation, protocol);
-        return subscription;
-    }
-
-    public Subscription createXpathSubscription(String topicExpression, String xpathExpression) throws Exception {
-        if (multipleThreadSupportIndex > numMultiThreadSupportPerSub) {
-            multipleThreadSupportIndex = 1;
-        }
-
-        String subscriptionId = client.subscribe(eprs[0] + "user" + multipleThreadSupportIndex++, topicExpression,
-                xpathExpression);
-        subscriptionIds.add(subscriptionId);
-        Subscription subscription = new Subscription(client, subscriptionId, topicExpression, xpathExpression, this,
-                brokerLocation, protocol);
-        return subscription;
-    }
-
-    public void cleanup() throws MsgBrokerClientException {
-
-        WseMsgBrokerClient wseClient = null;
-        WsntMsgBrokerClient wsntClient = null;
-
-        if ("wse".equalsIgnoreCase(this.protocol)) {
-            wseClient = (WseMsgBrokerClient) client;
-        } else {
-            wsntClient = (WsntMsgBrokerClient) client;
-        }
-
-        if (subscriptionIds != null) {
-            if (wseClient != null) {
-                while (!subscriptionIds.isEmpty()) {
-                    String subId = subscriptionIds.remove();
-                    wseClient.unSubscribe(subId);
-                }
-            } else {
-                while (!subscriptionIds.isEmpty()) {
-                    String subId = subscriptionIds.remove();
-                    wsntClient.unSubscribe(subId);
-                }
-
-            }
-        }
-
-        if (client != null) {
-            client.shutdownConsumerService();
-        }
-    }
-
-    private BlockingQueue<StatContainer> queue = new LinkedBlockingQueue<StatContainer>();
-    private int numMsgsReceived = 0;
-
-    public void handleNotification(SOAPEnvelope msgEnvelope) {
-        queue.add(new StatContainer(msgEnvelope));
-        numMsgsReceived += 1;
-    }
-
-    public BlockingQueue<StatContainer> getQueue() {
-        return queue;
-    }
-
-    public int getNumberOfMsgsReceived() {
-        return numMsgsReceived;
-    }
-
-    public synchronized void incNoTopicsSubscribed() {
-        numberOfTopicSubscribed++;
-    }
-
-    public synchronized int getNoTopicsSubscribed() {
-        return numberOfTopicSubscribed;
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/PerformanceTest.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/PerformanceTest.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/PerformanceTest.java
deleted file mode 100644
index 4e90ec0..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/PerformanceTest.java
+++ /dev/null
@@ -1,399 +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.wsmg.performance_evaluator.rtt;
-
-import java.io.BufferedWriter;
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.FileWriter;
-import java.io.IOException;
-import java.io.Writer;
-import java.net.URL;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Iterator;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Properties;
-import java.util.concurrent.CountDownLatch;
-
-import org.apache.airavata.wsmg.performance_evaluator.rtt.util.ConfigKeys;
-import org.apache.airavata.wsmg.performance_evaluator.rtt.util.LoadMsgPayload;
-import org.apache.airavata.wsmg.performance_evaluator.rtt.util.LoadXpath;
-
-class Stat {
-    String name;
-    Object value;
-
-    public Stat(String k, Object v) {
-        name = k;
-        value = v;
-    }
-
-}
-
-public class PerformanceTest {
-
-    public static int NOTIFICATIONS_PUBLISHED_PER_TOPIC = 0;
-    static String payload = null;
-    static LinkedList<String> xpathList = null;
-    public static long totalRoundTripTime = 0;
-    private static long avgRountTripTime = 0;
-    public static BufferedWriter out = null;
-    public static Properties configurations = null;
-    public static long avgPublishRTTime = 0l;
-    private static long totalPublishRTT = 0l;
-    private static int notifPerTopic = 0;
-    private static int noTopicsPublished = 0;
-    private static String protocol = "";
-    private static int payLoadMultiplier = 1;
-    private static int consumerPort = 3345;
-    private static long testExpirationTime = 0l;
-    private static int numberOfSubscriber = 0;
-    private static int numMultiThreadsSupportPerSub = 0;
-    private static String topicPrefix = "";
-
-    public static void main(String[] args) throws Exception {
-        loadConfigurationsFromFile();
-        testPerformance();
-    }
-
-    public static void testPerformance() throws Exception {
-
-        setConfigurationValues();
-        File outfile = new File("performance.log");
-        CountDownLatch publiserhStartSignal = new CountDownLatch(1);
-        CountDownLatch publisherDoneSignal = new CountDownLatch(noTopicsPublished);
-        NotificationManager notifManagerArray[] = new NotificationManager[numberOfSubscriber];
-        StatCalculatorThread statCalcThread[] = new StatCalculatorThread[numberOfSubscriber];
-        setPayload(payLoadMultiplier);
-
-        for (int j = 0; j < numberOfSubscriber; j++) {
-            notifManagerArray[j] = new NotificationManager(configurations.getProperty(ConfigKeys.BROKER_URL),
-                    consumerPort + j, protocol, numMultiThreadsSupportPerSub);
-
-        }
-
-        // thread to calculate stats for notification manager
-        // set the subscriptions depending on the topic or xpath based
-        int arrayIndex = 0;
-        int totalReceivers = 0;
-        createSubscriberArray(noTopicsPublished, numberOfSubscriber, notifManagerArray, arrayIndex);
-        System.out.println("subscribing to topics completed, creating publisher threads");
-
-        // start publishers
-        PublisherThread[] publisher = new PublisherThread[noTopicsPublished];
-        createPublishers(noTopicsPublished, protocol, publiserhStartSignal, publisherDoneSignal, publisher);
-        System.out.println("sending signal to start publishing...");
-        long publisherStartTime = System.currentTimeMillis();
-        long startTime = System.currentTimeMillis();
-        publiserhStartSignal.countDown(); // let all threads proceed
-
-        for (int j = 0; j < numberOfSubscriber; j++) {
-            statCalcThread[j] = new StatCalculatorThread(notifManagerArray[j], testExpirationTime);
-            statCalcThread[j].start();
-        }
-
-        publisherDoneSignal.await(); // wait for all to finish
-
-        for (int j = 0; j < noTopicsPublished; j++) {
-            totalPublishRTT += publisher[j].getAvgPubTime();
-        }
-
-        avgPublishRTTime = totalPublishRTT / noTopicsPublished;
-        long publishersRunningTime = System.currentTimeMillis() - publisherStartTime;
-        System.out.println("finished publishing messgaes.");
-
-        for (StatCalculatorThread stats : statCalcThread) {
-            stats.join();
-        }
-
-        long stopTime = 0l;
-        long totNumberOfMessagesReceived = 0;
-
-        for (StatCalculatorThread stats : statCalcThread) {
-            stopTime = stopTime < stats.getLastMsgReceivedTime() ? stats.getLastMsgReceivedTime() : stopTime;
-            totalRoundTripTime += stats.getTotalTime();
-            totNumberOfMessagesReceived += stats.getNumberOfMsgReceived();
-        }
-
-        for (NotificationManager notifMngr : notifManagerArray) {
-            totalReceivers += notifMngr.getNoTopicsSubscribed();
-        }
-
-        avgRountTripTime = totalRoundTripTime / totNumberOfMessagesReceived;
-        long executionTime = stopTime - startTime;
-        double throughtput = (totNumberOfMessagesReceived * 1000) / (executionTime);
-
-        List<Stat> statistics = new ArrayList<Stat>();
-
-        statistics.add(new Stat("Payload size (bytes)", payload.getBytes("US-ASCII").length));
-        statistics.add(new Stat("Protocol", protocol));
-        statistics.add(new Stat("# total expected Msgs", totalReceivers * notifPerTopic));
-        statistics.add(new Stat("# total msgs received", totNumberOfMessagesReceived));
-        setStatList(notifPerTopic, noTopicsPublished, publishersRunningTime, executionTime, throughtput, statistics);
-        printStatistics(statistics, outfile);
-
-        for (NotificationManager notifMngr : notifManagerArray) {
-            notifMngr.cleanup();
-        }
-
-        System.out.println("end of test");
-        System.exit(0);
-    }
-
-    private static void setConfigurationValues() {
-        notifPerTopic = Integer.parseInt(configurations.getProperty(ConfigKeys.NOTIFICATIONS_PUBLISHED_PER_TOPIC));
-        noTopicsPublished = Integer.parseInt(configurations.getProperty(ConfigKeys.NUMBER_OF_TOPICS_PUBLISHED));
-        protocol = configurations.getProperty(ConfigKeys.PROTOCOL);
-        payLoadMultiplier = Integer.parseInt(configurations.getProperty(ConfigKeys.PAYLOAD_MULTIPLYER));
-        consumerPort = Integer.parseInt(configurations.getProperty(ConfigKeys.CONSUMER_PORT));
-        testExpirationTime = Math.max(20000,
-                Long.parseLong(configurations.getProperty(ConfigKeys.PERFORMANCE_TEST_TIMEOUT, "20000")));
-        numberOfSubscriber = Integer.parseInt(configurations.getProperty(ConfigKeys.NUMBER_OF_SUBSCRIBERS));
-        numMultiThreadsSupportPerSub = Integer.parseInt(configurations.getProperty(ConfigKeys.MULTI_THREAD_PER_SUB));
-        topicPrefix = "topic" + configurations.getProperty(ConfigKeys.TOPIC_SIMPLE);
-        NOTIFICATIONS_PUBLISHED_PER_TOPIC = notifPerTopic;
-    }
-
-    private static void setStatList(int notifPerTopic, int noTopicsPublished, long publishersRunningTime,
-            long executionTime, double throughtput, List<Stat> statistics) {
-
-        statistics.add(new Stat("# topics published", noTopicsPublished));
-        statistics.add(new Stat("Total RTT (millis)", totalRoundTripTime));
-        statistics.add(new Stat("Average RTT (millis)", avgRountTripTime));
-        statistics.add(new Stat("Total published to receive time (millis)", executionTime));
-        statistics.add(new Stat("Throughput (messages per second)", throughtput));
-        statistics.add(new Stat("Total publish RTT (millis)", totalPublishRTT));
-        statistics.add(new Stat("Average publish RTT (millis)", avgPublishRTTime));
-        statistics.add(new Stat("publisher duration (millis)", publishersRunningTime));
-        statistics.add(new Stat("Publisher throughput (messages per second)", noTopicsPublished * notifPerTopic * 1000
-                / publishersRunningTime));
-    }
-
-    private static void setPayload(int payLoadMultiplier) {
-        String tempPayload = "";
-        try {
-            tempPayload = LoadMsgPayload.getInstance().getMessage("payload.txt");
-        } catch (FileNotFoundException e2) {
-            e2.printStackTrace();
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
-
-        for (int i = 1; i <= payLoadMultiplier; i++) {
-            payload += tempPayload;
-        }
-    }
-
-    private static void createPublishers(int noTopicsPublished, String protocol, CountDownLatch publiserhStartSignal,
-            CountDownLatch publisherDoneSignal, PublisherThread[] publisher) {
-        int threadId = 0;
-        for (int j = 0; j < noTopicsPublished; j++) {
-            threadId++;
-            publisher[j] = new PublisherThread(protocol, configurations.getProperty(ConfigKeys.BROKER_URL), topicPrefix
-                    + j, payload, publiserhStartSignal, publisherDoneSignal, threadId);
-            publisher[j].start();
-        }
-    }
-
-    private static void createSubscriberArray(int noTopicsPublished, int numberOfSubscriber,
-            NotificationManager[] notifManagerArray, int arrayIndex) throws Exception, IOException {
-        if ("false".equalsIgnoreCase(configurations.getProperty(ConfigKeys.IS_XPATH_ENABLED))) {
-            if (numberOfSubscriber <= noTopicsPublished) {
-                for (int i = 0; i < noTopicsPublished; ++i) {
-                    notifManagerArray[arrayIndex].createTopicSubscription(topicPrefix + i);
-                    notifManagerArray[arrayIndex++].incNoTopicsSubscribed();
-                    if (arrayIndex >= numberOfSubscriber) {
-                        arrayIndex = 0;
-                    }
-                }
-            } else {
-                int topicIndex = 0;
-                for (int i = 0; i < numberOfSubscriber; ++i) {
-                    notifManagerArray[i].createTopicSubscription(topicPrefix + topicIndex++);
-                    notifManagerArray[i].incNoTopicsSubscribed();
-                    if (topicIndex >= noTopicsPublished) {
-                        topicIndex = 0;
-                    }
-                }
-            }
-        } else {
-            xpathList = LoadXpath.getInstace().getXpathList("xpath.list");
-            if (numberOfSubscriber <= noTopicsPublished) {
-                Iterator<String> ite = xpathList.iterator();
-                for (int i = 0; i < noTopicsPublished; ++i) {
-                    if (!ite.hasNext())
-                        ite = xpathList.iterator();
-
-                    notifManagerArray[arrayIndex].createXpathSubscription(topicPrefix + i, ite.next());
-                    notifManagerArray[arrayIndex++].incNoTopicsSubscribed();
-                    if (arrayIndex >= numberOfSubscriber) {
-                        arrayIndex = 0;
-                    }
-                }
-            } else {
-                int topicIndex = 0;
-                for (int i = 0; i < numberOfSubscriber; ++i) {
-                    notifManagerArray[i].incNoTopicsSubscribed();
-                    if (topicIndex >= noTopicsPublished) {
-                        topicIndex = 0;
-                    }
-                }
-            }
-        }
-    }
-
-    private static Properties getDefaults() {
-        Properties defaults = new Properties();
-        defaults.setProperty(ConfigKeys.BROKER_URL, "http://localhost:8080/axis2/services/EventingService");
-        defaults.setProperty(ConfigKeys.TOPIC_SIMPLE, "simpleSampleTopic");
-        defaults.setProperty(ConfigKeys.CONSUMER_PORT, "6666");
-        defaults.setProperty(ConfigKeys.NOTIFICATIONS_PUBLISHED_PER_TOPIC, "5");
-        defaults.setProperty(ConfigKeys.NUMBER_OF_TOPICS_PUBLISHED, "5");
-        defaults.setProperty(ConfigKeys.IS_XPATH_ENABLED, "false");
-        defaults.setProperty(ConfigKeys.XPATH, "/c/b/a");
-        defaults.setProperty(ConfigKeys.PAYLOAD_MULTIPLYER, "1");
-        defaults.setProperty(ConfigKeys.PROTOCOL, "wse");
-        defaults.setProperty(ConfigKeys.PUBLISH_TIME_INTERVAL, "10000");
-        defaults.setProperty(ConfigKeys.PERFORMANCE_TEST_TIMEOUT, "5000000");
-        defaults.setProperty(ConfigKeys.NUMBER_OF_SUBSCRIBERS, "1");
-        defaults.setProperty(ConfigKeys.MULTI_THREAD_PER_SUB, "50");
-        return defaults;
-    }
-
-    private static void printStatistics(List<Stat> stats, File aFile) throws IOException {
-        int maxLen = 0;
-        Writer output = new BufferedWriter(new FileWriter(aFile, true));
-
-        for (Stat stat : stats) {
-            maxLen = Math.max(maxLen, stat.name.length());
-        }
-
-        char[] fillchars = null;
-
-        for (Stat stat : stats) {
-            fillchars = new char[maxLen - stat.name.length() + 1];
-            Arrays.fill(fillchars, ' ');
-            String formattedStr = String.format("%s%s : %s", stat.name, new String(fillchars), stat.value.toString());
-            output.write(formattedStr + "\n");
-            System.out.println(formattedStr);
-        }
-
-        fillchars = new char[maxLen];
-        Arrays.fill(fillchars, '-');
-        String fillingString = new String(fillchars);
-        output.write(fillingString + "\n");
-        System.out.println(fillingString);
-        output.close();
-    }
-
-    public static void loadConfigurationsFromFile() {
-        configurations = new Properties(getDefaults());
-
-        try {
-            URL url = ClassLoader.getSystemResource(ConfigKeys.CONFIG_FILE_NAME);
-            if (url == null) {
-                throw new IOException("configuration file not found");
-            }
-            configurations.load(url.openStream());
-        } catch (IOException ioe) {
-            System.out.println("unable to load configuration file, default settings will be used");
-        }
-    }
-
-    // Not used, If required to run as a test case call it from main
-    public static void loadConfigurationsFromSystemEnv() {
-
-        configurations = new Properties(getDefaults());
-
-        Properties envConfigs = System.getProperties();
-        String brokerUrl = envConfigs.getProperty(ConfigKeys.BROKER_URL, null);
-        String consumerUrl = envConfigs.getProperty(ConfigKeys.CONSUMER_EPR, null);
-        String consumerPort = envConfigs.getProperty(ConfigKeys.CONSUMER_PORT, null);
-        String isXpathEnabled = envConfigs.getProperty(ConfigKeys.IS_XPATH_ENABLED, null);
-        String notifPerTopic = envConfigs.getProperty(ConfigKeys.NOTIFICATIONS_PUBLISHED_PER_TOPIC, null);
-        String subsPerTopic = envConfigs.getProperty(ConfigKeys.NUMBER_OF_SUBS_PERTOPIC, null);
-        String noTopicsPublished = envConfigs.getProperty(ConfigKeys.NUMBER_OF_TOPICS_PUBLISHED, null);
-        String payLoadMultiplier = envConfigs.getProperty(ConfigKeys.PAYLOAD_MULTIPLYER, null);
-        String protocol = envConfigs.getProperty(ConfigKeys.PROTOCOL, null);
-        String topicSimple = envConfigs.getProperty(ConfigKeys.TOPIC_SIMPLE, null);
-        String topicXpath = envConfigs.getProperty(ConfigKeys.XPATH, null);
-
-        if (brokerUrl == null) {
-            System.err.println(ConfigKeys.BROKER_URL + " not given");
-            System.exit(1);
-        }
-        if (consumerUrl == null) {
-            System.err.println(ConfigKeys.CONSUMER_EPR + " not given");
-            System.exit(1);
-        }
-        if (consumerPort == null) {
-            System.err.println(ConfigKeys.CONSUMER_PORT + " not given");
-            System.exit(1);
-        }
-        if (isXpathEnabled == null) {
-            System.err.println(ConfigKeys.IS_XPATH_ENABLED + " not given");
-            System.exit(1);
-        }
-        if (notifPerTopic == null) {
-            System.err.println(ConfigKeys.NOTIFICATIONS_PUBLISHED_PER_TOPIC + " not given");
-            System.exit(1);
-        }
-        if (subsPerTopic == null) {
-            System.err.println(ConfigKeys.NUMBER_OF_SUBS_PERTOPIC + " not given");
-            System.exit(1);
-        }
-        if (noTopicsPublished == null) {
-            System.err.println(ConfigKeys.NUMBER_OF_TOPICS_PUBLISHED + " not given");
-            System.exit(1);
-        }
-        if (payLoadMultiplier == null) {
-            System.err.println(ConfigKeys.PAYLOAD_MULTIPLYER + " not given");
-            System.exit(1);
-        }
-        if (protocol == null) {
-            System.err.println(ConfigKeys.PROTOCOL + " not given");
-            System.exit(1);
-        }
-        if (topicSimple == null) {
-            System.err.println(ConfigKeys.TOPIC_SIMPLE + " not given");
-            System.exit(1);
-        }
-        if (topicXpath == null) {
-            System.err.println(ConfigKeys.XPATH + " not given");
-            System.exit(1);
-        }
-
-        configurations.put(ConfigKeys.BROKER_URL, brokerUrl);
-        configurations.put(ConfigKeys.CONSUMER_EPR, consumerUrl);
-        configurations.put(ConfigKeys.CONSUMER_PORT, consumerPort);
-        configurations.put(ConfigKeys.IS_XPATH_ENABLED, isXpathEnabled);
-        configurations.put(ConfigKeys.NOTIFICATIONS_PUBLISHED_PER_TOPIC, notifPerTopic);
-        configurations.put(ConfigKeys.NUMBER_OF_SUBS_PERTOPIC, subsPerTopic);
-        configurations.put(ConfigKeys.NUMBER_OF_TOPICS_PUBLISHED, noTopicsPublished);
-        configurations.put(ConfigKeys.PAYLOAD_MULTIPLYER, payLoadMultiplier);
-        configurations.put(ConfigKeys.PROTOCOL, protocol);
-        configurations.put(ConfigKeys.TOPIC_SIMPLE, topicSimple);
-        configurations.put(ConfigKeys.XPATH, topicXpath);
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/PublisherThread.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/PublisherThread.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/PublisherThread.java
deleted file mode 100644
index 4f1215b..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/PublisherThread.java
+++ /dev/null
@@ -1,99 +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.wsmg.performance_evaluator.rtt;
-
-import java.util.concurrent.CountDownLatch;
-
-import org.apache.airavata.wsmg.client.*;
-
-public class PublisherThread extends Thread {
-    private String brokerURL;
-    private String topic;
-    private final CountDownLatch startSignal;
-    private final CountDownLatch doneSignal;
-    private long totPublishTime = 0l;
-    long avgPublishTime = 0l;
-
-    private String payload = "";
-    String msg = "";
-    private MessageBrokerClient client = null;
-    int trackId = 0;
-    int threadId = 0;
-
-    public PublisherThread(String protocolIn, String brokerURLIn, String topicIn, String payloadIn,
-            CountDownLatch startSignalIn, CountDownLatch doneSignalIn, int threadIdIn) {
-        this.payload = payloadIn;
-        this.brokerURL = brokerURLIn;
-        this.topic = topicIn;
-        this.startSignal = startSignalIn;
-        this.doneSignal = doneSignalIn;
-        this.threadId = threadIdIn;
-        if ("wse".equalsIgnoreCase(protocolIn)) {
-
-            WseMsgBrokerClient wseMsgBrokerClient = new WseMsgBrokerClient();
-            wseMsgBrokerClient.setTimeoutInMilliSeconds(0);
-            wseMsgBrokerClient.init(brokerURL);
-            client = wseMsgBrokerClient;
-
-        } else {
-
-            WsntMsgBrokerClient wsntMsgBrokerClient = new WsntMsgBrokerClient();
-            wsntMsgBrokerClient.setTimeoutInMilliSeconds(0);
-            wsntMsgBrokerClient.init(brokerURL);
-            client = wsntMsgBrokerClient;
-        }
-
-    }
-
-    public void run() {
-
-        try {
-            trackId = 1;
-            startSignal.await();
-            System.out.println("Publishing started for topic :" + this.topic);
-            for (int i = 0; i < PerformanceTest.NOTIFICATIONS_PUBLISHED_PER_TOPIC; i++) {
-                msg = "<perf:performancetest xmlns:perf=\"http://lead.extreme.indiana.edu/namespaces/performance\"><perf:time>"
-                        + System.currentTimeMillis()
-                        + "</perf:time><perf:trackInfo><perf:threadId>"
-                        + threadId
-                        + "</perf:threadId><perf:trackId>"
-                        + trackId
-                        + "</perf:trackId></perf:trackInfo>"
-                        + "<perf:payload>" + payload + "</perf:payload></perf:performancetest>";
-                long publishStartTime = System.currentTimeMillis();
-                client.publish(topic, msg);
-                totPublishTime += System.currentTimeMillis() - publishStartTime;
-                trackId++;
-            }
-
-            avgPublishTime = totPublishTime / PerformanceTest.NOTIFICATIONS_PUBLISHED_PER_TOPIC;
-            System.out.println("Publishing ended for topic :" + this.topic);
-            doneSignal.countDown();
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-    }
-
-    synchronized long getAvgPubTime() {
-        return this.avgPublishTime;
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/StatCalculatorThread.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/StatCalculatorThread.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/StatCalculatorThread.java
deleted file mode 100644
index 541d80b..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/StatCalculatorThread.java
+++ /dev/null
@@ -1,103 +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.wsmg.performance_evaluator.rtt;
-
-import java.util.concurrent.TimeUnit;
-
-public class StatCalculatorThread extends Thread {
-
-    private NotificationManager notifManager = null;
-    private long lastMsgReceivedTime = 0l;
-    private long timeTot = 0;
-    private long avgTime = 0;
-    private int numberOfMssgsReceived = 0; // to avoid concurrency
-    private long timeOutMillis;
-    private int expectedNoMessages = 0;
-
-    public StatCalculatorThread(NotificationManager notificationManager, long timeOutInMillis) throws Exception {
-        this.timeOutMillis = timeOutInMillis;
-        this.notifManager = notificationManager;
-        expectedNoMessages = PerformanceTest.NOTIFICATIONS_PUBLISHED_PER_TOPIC
-                * notificationManager.getNoTopicsSubscribed();
-    }
-
-    @Override
-    public void run() {
-        do {
-
-            StatContainer container = null;
-            try {
-                container = notifManager.getQueue().poll(timeOutMillis, TimeUnit.MILLISECONDS);
-
-                if (container != null) {
-                    timeTot += container.getRondTripTime();
-                    lastMsgReceivedTime = container.getMessageReceivedTime();
-                    numberOfMssgsReceived++;
-                    // ******un-comment in order to log trakId and message
-                    // related other information*****
-                    // if (logger.isInfoEnabled()) {
-                    // trackInfo = env
-                    // .getBody()
-                    // .getFirstElement()
-                    // .getFirstChildWithName(
-                    // new QName(
-                    // "http://lead.extreme.indiana.edu/namespaces/performance",
-                    // "trackInfo")).toStringWithConsume();
-                    // logger.info(trackInfo + "   Send time :" + time
-                    // + "  Received time :" + System.currentTimeMillis());
-                    // }
-                } else {
-                    System.out.println("stat calculator thread was interrupted");
-                    break;
-                }
-            } catch (InterruptedException e1) {
-                e1.printStackTrace();
-                break;
-            }
-
-        } while (expectedNoMessages > numberOfMssgsReceived);
-
-        if (numberOfMssgsReceived > 0) {
-            avgTime = timeTot / numberOfMssgsReceived;
-        } else {
-            System.out.println("no messages received");
-        }
-
-        System.out.println("end of stat calculator");
-    }
-
-    synchronized long getTotalTime() {
-        return timeTot;
-    }
-
-    synchronized long getAverageTime() {
-        return avgTime;
-    }
-
-    synchronized long getNumberOfMsgReceived() {
-        return numberOfMssgsReceived;
-    }
-
-    synchronized public long getLastMsgReceivedTime() {
-        return lastMsgReceivedTime;
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/StatContainer.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/StatContainer.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/StatContainer.java
deleted file mode 100644
index 31b9c85..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/StatContainer.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.wsmg.performance_evaluator.rtt;
-
-import org.apache.axiom.soap.SOAPEnvelope;
-
-public class StatContainer {
-    private SOAPEnvelope msgEnvelope = null;
-    private long rtt = 0l;
-    private long receivedTime = 0l;
-
-    public StatContainer(SOAPEnvelope msgEnvelope) {
-        this.msgEnvelope = msgEnvelope;
-        this.receivedTime = System.currentTimeMillis();
-        this.rtt = this.receivedTime
-                - Long.parseLong(msgEnvelope.getBody().getFirstElement().getFirstElement().getText());
-    }
-
-    public long getRondTripTime() {
-        return this.rtt;
-    }
-
-    public SOAPEnvelope getMsgEnvelope() {
-        return msgEnvelope;
-    }
-
-    public long getMessageReceivedTime() {
-        return this.receivedTime;
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/Subscription.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/Subscription.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/Subscription.java
deleted file mode 100644
index d8df04f..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/Subscription.java
+++ /dev/null
@@ -1,107 +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.wsmg.performance_evaluator.rtt;
-
-import org.apache.airavata.wsmg.client.ConsumerNotificationHandler;
-import org.apache.airavata.wsmg.client.MessageBrokerClient;
-import org.apache.axis2.addressing.EndpointReference;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class Subscription {
-
-    private String subscriptionID;
-
-    private String topic;
-    private final static Logger logger = LoggerFactory.getLogger(Subscription.class);
-    private ConsumerNotificationHandler handler;
-    private MessageBrokerClient client;
-    private EndpointReference messageBoxEPR;
-    private String xpath;
-    private String brokerURL;
-
-    private String protocol;
-
-    public Subscription(MessageBrokerClient clientIn, String subscriptionID, String topic,
-            ConsumerNotificationHandler callback, String brokerURL, String protocolIn) {
-        super();
-        this.subscriptionID = subscriptionID;
-        this.topic = topic;
-        this.handler = callback;
-        this.brokerURL = brokerURL;
-        this.client = clientIn;
-        this.protocol = protocolIn;
-    }
-
-    public Subscription(MessageBrokerClient clientIn, String subscriptionID, String topic, String xpath,
-            ConsumerNotificationHandler callback, String brokerURL, String protocolIn) {
-        super();
-        this.client = clientIn;
-        this.subscriptionID = subscriptionID;
-        this.topic = topic;
-        this.handler = callback;
-        this.brokerURL = brokerURL;
-        this.xpath = xpath;
-        this.protocol = protocolIn;
-    }
-
-    public ConsumerNotificationHandler getCallback() {
-        return handler;
-    }
-
-    public String getTopic() {
-        return topic;
-    }
-
-    // public void destroy() throws RemoteException {
-    // client.shutdownConsumerService();
-    // }
-
-    public EndpointReference getMessageBoxEPR() {
-        return messageBoxEPR;
-    }
-
-    public void setMessageBoxEpr(EndpointReference messageBoxEPR) {
-        this.messageBoxEPR = messageBoxEPR;
-    }
-
-    public String getSubscriptionID() {
-        return subscriptionID;
-    }
-
-    public void setSubscriptionID(String subscriptionID) {
-        this.subscriptionID = subscriptionID;
-    }
-
-    public String getBrokerURL() {
-        return brokerURL;
-    }
-
-    public void setBrokerURL(String brokerURL) {
-        this.brokerURL = brokerURL;
-    }
-
-    // public String getConsumerEPR() throws UnknownHostException {
-    // cli
-    // }
-
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/ConfigKeys.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/ConfigKeys.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/ConfigKeys.java
deleted file mode 100644
index 6463f31..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/ConfigKeys.java
+++ /dev/null
@@ -1,43 +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.wsmg.performance_evaluator.rtt.util;
-
-public interface ConfigKeys {
-    String CONFIG_FILE_NAME = "configurations.properties";
-    String BROKER_URL = "broker.eventing.service.epr";
-    String CONSUMER_EPR = "consumer.location";
-    String CONSUMER_PORT = "consumer.port";
-    String TOPIC_SIMPLE = "topic.simple";
-    String TOPIC_XPATH = "topic.xpath";
-    String PUBLISH_TIME_INTERVAL = "publish.time.interval";
-    String IS_XPATH_ENABLED = "is.xpath.enabled";
-    String XPATH = "topic.xpath";
-    String PAYLOAD_MULTIPLYER = "payload.multiplyer";
-    String PROTOCOL = "protocol.used";
-    String NUMBER_OF_SUBS_PERTOPIC = "num.subscribers.per.topic";
-    String NOTIFICATIONS_PUBLISHED_PER_TOPIC = "notifications.per.topic";
-    String NUMBER_OF_TOPICS_PUBLISHED = "number.of.topics";
-    String SCHEDULER_REPEAT_PERIOD = "stat.timeout.monitor.scheduler.period";
-    String PERFORMANCE_TEST_TIMEOUT = "performance.test.timeout.period.millis";
-    String NUMBER_OF_SUBSCRIBERS = "number.of.subscriber.servers";
-    String MULTI_THREAD_PER_SUB = "num.muti.thread.per.sub";
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/LoadMsgPayload.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/LoadMsgPayload.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/LoadMsgPayload.java
deleted file mode 100644
index 8ed4cb6..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/LoadMsgPayload.java
+++ /dev/null
@@ -1,66 +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.wsmg.performance_evaluator.rtt.util;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.net.URL;
-
-public class LoadMsgPayload {
-
-    private static LoadMsgPayload msg = null;
-
-    public static LoadMsgPayload getInstance() {
-        if (msg == null)
-            msg = new LoadMsgPayload();
-        return msg;
-    }
-
-    public String getMessage(String fileName) throws IOException {
-        URL url = ClassLoader.getSystemResource(fileName);
-        if (url != null)
-            return convertStreamToString(url.openStream());
-        else
-            return "";
-    }
-
-    private String convertStreamToString(InputStream is) throws IOException {
-        if (is != null) {
-            StringBuilder sb = new StringBuilder();
-            String line;
-
-            try {
-                BufferedReader reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));
-                while ((line = reader.readLine()) != null) {
-                    sb.append(line).append("\n");
-                }
-            } finally {
-                is.close();
-            }
-            return sb.toString();
-        } else {
-            return "";
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/LoadXpath.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/LoadXpath.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/LoadXpath.java
deleted file mode 100644
index 1a1a5fa..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/performance_evaluator/rtt/util/LoadXpath.java
+++ /dev/null
@@ -1,66 +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.wsmg.performance_evaluator.rtt.util;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.net.URL;
-import java.util.LinkedList;
-
-public class LoadXpath {
-    private static LoadXpath xpath = null;
-    LinkedList<String> xpathList = null;
-
-    public static LoadXpath getInstace() {
-        if (xpath == null)
-            xpath = new LoadXpath();
-        return xpath;
-    }
-
-    public LinkedList<String> getXpathList(String fileName) throws IOException {
-        URL url = ClassLoader.getSystemResource(fileName);
-        if (url != null && xpathList == null)
-            return convertStreamToString(url.openStream());
-        return xpathList;
-    }
-
-    private LinkedList<String> convertStreamToString(InputStream is) throws IOException {
-        if (is != null) {
-            xpathList = new LinkedList<String>();
-            String line;
-
-            try {
-                BufferedReader reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));
-                while ((line = reader.readLine()) != null) {
-                    xpathList.add(line);
-                }
-            } finally {
-                is.close();
-            }
-            return xpathList;
-        } else {
-            return null;
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/util/BrokerUtilTest.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/util/BrokerUtilTest.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/util/BrokerUtilTest.java
deleted file mode 100644
index e0162e7..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/util/BrokerUtilTest.java
+++ /dev/null
@@ -1,167 +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.wsmg.util;
-
-import javax.xml.namespace.QName;
-
-import junit.framework.TestCase;
-
-import org.apache.airavata.wsmg.commons.WsmgCommonConstants;
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMFactory;
-import org.apache.axiom.om.OMNamespace;
-import org.apache.axis2.AxisFault;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-public class BrokerUtilTest extends TestCase {
-
-    /**
-     * @throws java.lang.Exception
-     */
-    @Before
-    public void setUp() throws Exception {
-    }
-
-    /**
-     * @throws java.lang.Exception
-     */
-    @After
-    public void tearDown() throws Exception {
-    }
-
-    /**
-     * Test method for
-     * {@link org.apache.airavata.wsmg.util.BrokerUtil#sameStringValue(java.lang.String, java.lang.String)} .
-     */
-    @Test
-    public void testSameStringValue() {
-
-        assertTrue(BrokerUtil.sameStringValue(null, null));
-        assertTrue(BrokerUtil.sameStringValue("test", "test"));
-
-        assertFalse(BrokerUtil.sameStringValue("one", "two"));
-        assertFalse(BrokerUtil.sameStringValue(null, "test"));
-        assertFalse(BrokerUtil.sameStringValue("test", null));
-
-    }
-
-    /**
-     * Test method for {@link org.apache.airavata.wsmg.util.BrokerUtil#getTopicLocalString(java.lang.String)}.
-     */
-    @Test
-    public void testGetTopicLocalString() {
-
-        assertEquals("localstring", (BrokerUtil.getTopicLocalString("prefix:localstring")));
-
-        assertEquals("localstring", BrokerUtil.getTopicLocalString("localstring"));
-
-    }
-
-    /**
-     * Test method for {@link org.apache.airavata.wsmg.util.BrokerUtil#getXPathString(org.apache.axiom.om.OMElement)}.
-     */
-    @Test
-    public void testGetXPathString() {
-
-        OMFactory factory = OMAbstractFactory.getOMFactory();
-
-        try {
-
-            BrokerUtil.getXPathString(null);
-            fail("method should validate invalid arguments");
-        } catch (IllegalArgumentException e) {
-
-        } catch (AxisFault e) {
-            fail("invalid exception thrown");
-        }
-
-        try {
-
-            QName invalidQName = new QName("invalidURI", "invalidLocalName");
-
-            OMElement xpathEl = factory.createOMElement(invalidQName);
-
-            BrokerUtil.getXPathString(xpathEl);
-
-            fail("method should validate arguments");
-
-        } catch (AxisFault fault) {
-
-        }
-
-        try {
-
-            String xpathExpression = "testXpathExpression";
-            String dialect = "unknownXpathDialect";
-
-            OMNamespace ns = factory.createOMNamespace("unit_test", "jnt");
-
-            OMElement xpathEl = factory.createOMElement("TestXpath", ns);
-            xpathEl.addAttribute("Dialect", dialect, null);
-
-            xpathEl.setText(xpathExpression);
-
-            BrokerUtil.getXPathString(xpathEl);
-
-            fail("method should reject unknown dialect");
-        } catch (AxisFault e) {
-
-        }
-
-        try {
-
-            String xpathExpression = "textXpathExpression";
-            String dialect = WsmgCommonConstants.XPATH_DIALECT;
-
-            OMNamespace ns = factory.createOMNamespace("unit_test", "jnt");
-
-            OMElement xpathEl = factory.createOMElement("TestXpath", ns);
-            xpathEl.addAttribute("Dialect", dialect, null);
-
-            xpathEl.setText(xpathExpression);
-            assertEquals(xpathExpression, BrokerUtil.getXPathString(xpathEl));
-
-        } catch (AxisFault e) {
-            fail("unable to extract xpath query: " + e.toString());
-        }
-
-    }
-
-    /**
-     * Test method for {@link org.apache.airavata.wsmg.util.BrokerUtil#getTopicFromRequestPath(java.lang.String)}.
-     */
-    @Test
-    public void testGetTopicFromRequestPath() {
-
-        assertNull(BrokerUtil.getTopicFromRequestPath(null));
-        assertNull(BrokerUtil.getTopicFromRequestPath(""));
-        assertNull(BrokerUtil.getTopicFromRequestPath("/"));
-        assertNull(BrokerUtil.getTopicFromRequestPath("/subscribe/url/"));
-        assertNull(BrokerUtil.getTopicFromRequestPath("/subscribe/url/topic/"));
-
-        assertEquals(BrokerUtil.getTopicFromRequestPath("/requestpath/topic/xyz"), "xyz");
-
-    }
-}

http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/util/ConfigKeys.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/util/ConfigKeys.java b/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/util/ConfigKeys.java
deleted file mode 100644
index 0624442..0000000
--- a/modules/ws-messenger/messagebroker/src/test/java/org/apache/airavata/wsmg/util/ConfigKeys.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.wsmg.util;
-
-public interface ConfigKeys {
-
-    String CONFIG_FILE_NAME = "unit_tests.properties";
-
-    String CONSUMER_EPR = "consumer.location";
-    String CONSUMER_PORT = "consumer.port";
-    String TOPIC_SIMPLE = "topic.simple";
-    String TOPIC_XPATH = "topic.xpath";
-    String AXIS2_REPO = "axis2.repo";
-
-}


Mime
View raw message