You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2015/01/27 16:26:56 UTC
[02/13] airavata git commit: retiring ws-messenger and remove
dependency of workflow tracking - AIRAVATA-1556, AIRAVATA-1557
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";
-
-}