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:27:04 UTC
[10/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/client/src/main/java/org/apache/airavata/wsmg/client/msgbox/MsgboxHandler.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/msgbox/MsgboxHandler.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/msgbox/MsgboxHandler.java
deleted file mode 100644
index 5b06610..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/msgbox/MsgboxHandler.java
+++ /dev/null
@@ -1,122 +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.client.msgbox;
-
-import java.rmi.RemoteException;
-
-import javax.xml.namespace.QName;
-
-import org.apache.airavata.wsmg.client.MsgBrokerClientException;
-import org.apache.airavata.wsmg.client.NotificationHandler;
-import org.apache.airavata.wsmg.commons.MsgBoxQNameConstants;
-import org.apache.airavata.wsmg.msgbox.client.MsgBoxClient;
-import org.apache.axis2.addressing.EndpointReference;
-
-public class MsgboxHandler {
-
- protected MsgBoxClient msgBoxUser = null;
-
- public EndpointReference createPullMsgBox(String msgBoxLocation, long timeout) throws MsgBrokerClientException {
- msgBoxUser = new MsgBoxClient();
- EndpointReference msgBoxAddr = null;
-
- try {
- msgBoxAddr = msgBoxUser.createMessageBox(msgBoxLocation, timeout);
- } catch (RemoteException e) {
- throw new MsgBrokerClientException("unable to create msgbox", e);
- }
-
- return msgBoxAddr;
- }
-
- public EndpointReference createPullMsgBox(String msgBoxServerLoc) throws MsgBrokerClientException {
- return createPullMsgBox(msgBoxServerLoc, 12000L);
- }
-
- public MessagePuller startPullingEventsFromMsgBox(EndpointReference msgBoxEpr, NotificationHandler handler,
- long interval, long timeout) throws MsgBrokerClientException {
- if (msgBoxUser == null) {
- throw new MsgBrokerClientException("Unable start pulling, the messagebox client was not initialized");
- }
-
- MessagePuller messagePuller = new MessagePuller(msgBoxUser, msgBoxEpr, handler, interval, timeout);
- messagePuller.startPulling();
- return messagePuller;
- }
-
- public MessagePuller startPullingFromExistingMsgBox(EndpointReference msgBoxAddr, NotificationHandler handler,
- long interval, long timeout) throws MsgBrokerClientException {
-
- String toAddress = msgBoxAddr.getAddress();
- int biginIndex = toAddress.indexOf("clientid");
- String clientId = toAddress.substring(biginIndex + "clientid".length() + 1);
-
- if ((msgBoxAddr.getAllReferenceParameters() == null || msgBoxAddr.getAllReferenceParameters()
- .get(MsgBoxQNameConstants.MSG_BOXID_QNAME).getText() == null)
- && biginIndex == -1)
- throw new MsgBrokerClientException("Invalid Message Box Address");
- this.msgBoxUser = new MsgBoxClient();
- MessagePuller messagePuller = new MessagePuller(msgBoxUser, msgBoxAddr, handler, interval, timeout);
- messagePuller.startPulling();
- return messagePuller;
- }
-
- public String deleteMsgBox(EndpointReference msgBoxEpr, long timeout) throws MsgBrokerClientException {
-
- String msgBoxEventSink = msgBoxEpr.getAddress();
-
- String formattedEventSink = null;
-
- if (msgBoxEpr.getAddress().contains("clientid")) {
- formattedEventSink = msgBoxEventSink;
- } else {
- if (msgBoxEpr.getAllReferenceParameters() == null)
- throw new MsgBrokerClientException("Invalid Message Box EPR, no reference parameters found");
- String msgBoxId = msgBoxEpr.getAllReferenceParameters().get(MsgBoxQNameConstants.MSG_BOXID_QNAME).getText();
- if (msgBoxId == null)
- throw new MsgBrokerClientException(
- "Invalid Message Box EPR, reference parameter MsgBoxAddress is missing");
- String format = msgBoxEventSink.endsWith("/") ? "%sclientid/%s" : "%s/clientid/%s";
-
- formattedEventSink = String.format(format, msgBoxEventSink, msgBoxId);
-
- }
-
- if (this.msgBoxUser == null) {
- this.msgBoxUser = new MsgBoxClient();
- }
-
- String resp = null;
- try {
- resp = msgBoxUser.deleteMsgBox(msgBoxEpr, timeout);
- } catch (RemoteException e) {
- throw new MsgBrokerClientException("unable to delete the msg box", e);
- }
-
- return resp;
- }
-
- public void stopPullingEventsFromMsgBox(MessagePuller msgPuller) {
- msgPuller.stopPulling();
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/protocol/WSEProtocolClient.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/protocol/WSEProtocolClient.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/protocol/WSEProtocolClient.java
deleted file mode 100644
index c8f4d31..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/protocol/WSEProtocolClient.java
+++ /dev/null
@@ -1,146 +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.client.protocol;
-
-import javax.xml.namespace.QName;
-
-import org.apache.airavata.wsmg.commons.WsmgCommonConstants;
-import org.apache.airavata.wsmg.commons.NameSpaceConstants;
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMFactory;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.addressing.EndpointReferenceHelper;
-
-public class WSEProtocolClient {
-
- public static EndpointReference createEndpointReference(String brokerURL, String topic) {
- if (brokerURL == null) {
- throw new IllegalArgumentException("Broker URL is null.");
- }
- if (topic == null) {
- throw new IllegalArgumentException("Topic is null.");
- }
-
- String sinkLocation = brokerURL.endsWith("/") ? brokerURL + "topic/" + topic : brokerURL + "/topic/" + topic;
-
- EndpointReference eventSinkReference = new EndpointReference(sinkLocation);
- return eventSinkReference;
- }
-
- private static OMElement createFilter(String topicExpression, String xpathExpression) {
-
- boolean hasTopicExpression = (topicExpression != null && topicExpression.length() != 0);
- boolean hasXPathExpression = (xpathExpression != null && xpathExpression.length() != 0);
-
- OMFactory factory = OMAbstractFactory.getOMFactory();
- OMElement filterEl = null;
-
- if (hasTopicExpression && hasXPathExpression) {
- filterEl = factory.createOMElement("Filter", NameSpaceConstants.WSE_NS);
-
- filterEl.addAttribute("Dialect", WsmgCommonConstants.TOPIC_AND_XPATH_DIALECT, null);
- OMElement topicExpressionEl = factory.createOMElement("TopicExpression", NameSpaceConstants.WSNT_NS);
- topicExpressionEl.addAttribute("Dialect", WsmgCommonConstants.TOPIC_EXPRESSION_SIMPLE_DIALECT, null);
- topicExpressionEl.declareNamespace(NameSpaceConstants.WIDGET_NS);
- topicExpressionEl.setText(NameSpaceConstants.WIDGET_NS.getPrefix() + ":" + topicExpression);
- filterEl.addChild(topicExpressionEl);
- OMElement xpathEl = factory.createOMElement("MessageContent", NameSpaceConstants.WSNT_NS);
- xpathEl.addAttribute("Dialect", WsmgCommonConstants.XPATH_DIALECT, null);
- xpathEl.setText(xpathExpression);
- filterEl.addChild(xpathEl);
- } else if (hasTopicExpression) {
- filterEl = factory.createOMElement("Filter", NameSpaceConstants.WSE_NS);
-
- filterEl.addAttribute("Dialect", WsmgCommonConstants.TOPIC_EXPRESSION_SIMPLE_DIALECT, null);
- filterEl.declareNamespace(NameSpaceConstants.WIDGET_NS);
- filterEl.setText(NameSpaceConstants.WIDGET_NS.getPrefix() + ":" + topicExpression);
- } else if (hasXPathExpression) {
- filterEl = factory.createOMElement("Filter", NameSpaceConstants.WSE_NS);
-
- filterEl.addAttribute("Dialect", WsmgCommonConstants.XPATH_DIALECT, null);
- filterEl.setText(xpathExpression);
- }
-
- return filterEl;
- }
-
- public static OMElement createSubscription(EndpointReference eventSink, String topicExpression,
- String xpathExpression, long expireTime) throws AxisFault {
-
- OMFactory factory = OMAbstractFactory.getOMFactory();
- OMElement subscribeMsg = factory.createOMElement("Subscribe", NameSpaceConstants.WSE_NS);
-
- OMElement delivery = factory.createOMElement("Delivery", NameSpaceConstants.WSE_NS);
-
- OMElement expires = factory.createOMElement("Expires", NameSpaceConstants.WSE_NS);
- expires.setText(Long.toString(expireTime));
- subscribeMsg.addChild(expires);
-
- OMElement notifyTo = EndpointReferenceHelper.toOM(factory, eventSink,
- new QName(NameSpaceConstants.WSE_NS.getNamespaceURI(), "NotifyTo"),
- NameSpaceConstants.WSA_NS.getNamespaceURI());
-
- delivery.addChild(notifyTo);
- subscribeMsg.addChild(delivery);
-
- OMElement filterEl = createFilter(topicExpression, xpathExpression);
-
- if (filterEl != null) {
- subscribeMsg.addChild(filterEl);
- }
-
- subscribeMsg.declareNamespace(NameSpaceConstants.WSA_NS);
-
- return subscribeMsg;
- }
-
- public static String decodeSubscribeResponse(OMElement responseSubscriptionsManagerElement) throws AxisFault {
- String subscriptionId = null;
- OMElement referencePropertiesEl = responseSubscriptionsManagerElement.getFirstChildWithName(new QName(
- NameSpaceConstants.WSA_NS.getNamespaceURI(), "ReferenceProperties"));
-
- if (referencePropertiesEl == null) {
- referencePropertiesEl = responseSubscriptionsManagerElement.getFirstChildWithName(new QName(
- NameSpaceConstants.WSA_NS.getNamespaceURI(), "ReferenceParameters"));
- }
-
- OMElement identifierEl = referencePropertiesEl.getFirstChildWithName(new QName(NameSpaceConstants.WSE_NS
- .getNamespaceURI(), WsmgCommonConstants.SUBSCRIPTION_ID));
-
- if (identifierEl == null) {
- throw new AxisFault("invalid response message, subscription id was not sent by broker");
- }
-
- subscriptionId = identifierEl.getText();
- return subscriptionId;
- }
-
- public static OMElement createUnsubscribeMsg() {
- OMFactory factory = OMAbstractFactory.getOMFactory();
- OMElement message = factory.createOMElement("Unsubscribe", NameSpaceConstants.WSE_NS);
-
- return message;
- }
-
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/protocol/WSNTProtocolClient.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/protocol/WSNTProtocolClient.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/protocol/WSNTProtocolClient.java
deleted file mode 100644
index a582e72..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/protocol/WSNTProtocolClient.java
+++ /dev/null
@@ -1,127 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.wsmg.client.protocol;
-
-import java.util.Map;
-
-import javax.xml.namespace.QName;
-
-import org.apache.airavata.wsmg.commons.WsmgCommonConstants;
-import org.apache.airavata.wsmg.commons.NameSpaceConstants;
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMFactory;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.addressing.EndpointReferenceHelper;
-
-public class WSNTProtocolClient {
-
- public static OMElement createSubscriptionMsg(EndpointReference eventSinkLocation, String topicExpression,
- String xpathExpression) throws AxisFault {
- OMFactory factory = OMAbstractFactory.getOMFactory();
-
- OMElement message = factory.createOMElement("SubscribeRequest", NameSpaceConstants.WSNT_NS);
-
- if (topicExpression != null) {
- OMElement topicExpEl = factory.createOMElement("TopicExpression", NameSpaceConstants.WSNT_NS, message);
-
- topicExpEl.addAttribute("Dialect", WsmgCommonConstants.TOPIC_EXPRESSION_SIMPLE_DIALECT,
- NameSpaceConstants.WSNT_NS);
- topicExpEl.declareNamespace(NameSpaceConstants.WIDGET_NS);
- topicExpEl.setText(NameSpaceConstants.WIDGET_NS.getPrefix() + ":" + topicExpression);
- }
-
- if (xpathExpression != null) {
- OMElement xpathExpEl = factory.createOMElement("Selector", NameSpaceConstants.WSNT_NS, message);
- xpathExpEl.addAttribute("Dialect", WsmgCommonConstants.XPATH_DIALECT, null);
- xpathExpEl.setText(xpathExpression);
- }
-
- OMElement useNotifyEl = factory.createOMElement("UseNotify", message.getNamespace(), message);
- useNotifyEl.setText("true");// check wether we still need this
-
- OMElement eprCrEl = EndpointReferenceHelper.toOM(factory, eventSinkLocation, new QName("ConsumerReference"),
- NameSpaceConstants.WSA_NS.getNamespaceURI());
-
- message.addChild(eprCrEl);
- eprCrEl.setNamespace(message.getNamespace());
-
- return message;
- }
-
- public static String decodeSubscriptionResponse(OMElement subscriptionReference) throws AxisFault {
-
- String subscriptionId = null;
-
- EndpointReference subscriptionReferenceEPR = EndpointReferenceHelper.fromOM(subscriptionReference);
-
- Map<QName, OMElement> referenceParams = subscriptionReferenceEPR.getAllReferenceParameters();
-
- if (referenceParams != null) {
- QName identifierQName = new QName(NameSpaceConstants.WSNT_NS.getNamespaceURI(),
- WsmgCommonConstants.SUBSCRIPTION_ID);
-
- OMElement identifierEl = referenceParams.get(identifierQName);
- subscriptionId = (identifierEl != null) ? identifierEl.getText() : null;
-
- }
-
- return subscriptionId;
- }
-
- public static OMElement createUnsubscribeMsg() {
- OMFactory factory = OMAbstractFactory.getOMFactory();
- OMElement message = factory.createOMElement("UnsubsribeRequest", NameSpaceConstants.WSNT_NS);
-
- return message;
- }
-
- public static OMElement encodeNotification(String topic, OMElement message, EndpointReference producerReference)
- throws AxisFault {
- OMFactory factory = OMAbstractFactory.getOMFactory();
-
- OMElement topicExpEl = factory.createOMElement("Topic", NameSpaceConstants.WSNT_NS);
- topicExpEl.addAttribute("Dialect", WsmgCommonConstants.TOPIC_EXPRESSION_SIMPLE_DIALECT, null);
- topicExpEl.declareNamespace(NameSpaceConstants.WIDGET_NS);
- topicExpEl.setText(NameSpaceConstants.WIDGET_NS.getPrefix() + ":" + topic);
-
- OMElement messageToNotify = factory.createOMElement("Notify", NameSpaceConstants.WSNT_NS);
- messageToNotify.declareNamespace(NameSpaceConstants.WSNT_NS);
- messageToNotify.declareNamespace(NameSpaceConstants.WSA_NS);
- OMElement notificationMesssageEl = factory.createOMElement("NotificationMessage",
- messageToNotify.getNamespace(), messageToNotify);
-
- notificationMesssageEl.addChild(topicExpEl);
-
- notificationMesssageEl.addChild(EndpointReferenceHelper.toOM(factory, producerReference, new QName(
- notificationMesssageEl.getNamespace().getNamespaceURI(), "ProducerReference", notificationMesssageEl
- .getNamespace().getPrefix()), NameSpaceConstants.WSA_NS.getNamespaceURI()));
-
- OMElement messageEl = factory.createOMElement("Message", notificationMesssageEl.getNamespace(),
- notificationMesssageEl);
-
- messageEl.addChild(message);
- return messageToNotify;
- }
-
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/util/ClientUtil.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/util/ClientUtil.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/util/ClientUtil.java
deleted file mode 100644
index 5937898..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/util/ClientUtil.java
+++ /dev/null
@@ -1,58 +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.client.util;
-
-import java.net.InetAddress;
-import java.net.UnknownHostException;
-
-public class ClientUtil {
-
- public static final long EXPIRE_TIME = 1000 * 60 * 60 * 72l;
-
- public static String formatMessageBoxUrl(String msgBoxServiceUrl, String msgboxId) {
- return msgBoxServiceUrl.endsWith("/") ? msgBoxServiceUrl + "clientid/" + msgboxId : msgBoxServiceUrl
- + "/clientid/" + msgboxId;
- }
-
- public static String formatURLString(String url) {
- if (url == null) {
- throw new IllegalArgumentException("url can't be null");
- }
- if (url.indexOf("//") < 0) {
- url = "http://" + url; // use default http
- }
- return url;
- }
-
- public static String getHostIP() {
- InetAddress localAddress = null;
- try {
- localAddress = InetAddress.getLocalHost();
- } catch (UnknownHostException ex) {
- System.out.println("Error - unable to resolve localhost");
- }
- // Use IP address since DNS entry cannot update the laptop's entry
- // promptly
- String hostIP = localAddress.getHostAddress();
- return hostIP;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/util/DcDate.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/util/DcDate.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/util/DcDate.java
deleted file mode 100644
index 24b57cf..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/util/DcDate.java
+++ /dev/null
@@ -1,472 +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.client.util;
-
-import java.util.ArrayList;
-import java.util.Calendar;
-import java.util.GregorianCalendar;
-import java.util.Iterator;
-import java.util.List;
-import java.util.TimeZone;
-
-//TODO: support for fractional seconds
-
-/**
- * Represent dc:date as an immutable value object. http://www.w3.org/TR/NOTE-datetime
- * http://www.sics.se/~preben/DC/date_help.html
- *
- */
-public final class DcDate implements Cloneable {
-
- public Object clone() throws CloneNotSupportedException {
- // it is easy as object is immutable
- DcDate dd = (DcDate) super.clone();
- return dd;
- }
-
- private String canonical;
-
- // private Date date;
- private int year;
-
- private int month; // 1-12
-
- private int day; // 1-31
-
- private int hh = -1; // 00-23
-
- private int mm = -1; // 00-59
-
- private int ss = -1; // 00-59
-
- private String decimalFraction = null; // decimal fraction
-
- private int zoneOffset; // in minutes +/-(12*60) ???
-
- private Calendar instant;
-
- private int millisOffset = -1; // milliseconds
-
- // public DcDate() throws SException {
- //
- // this(System.currentTimeMillis());
- // }
- //
- // public DcDate(long timeMillis) throws SException {
- // this(timeMillis, null);
- // Calendar local = new GregorianCalendar();
- // local.setTimeInMillis(timeMillis);
- // }
-
- // public DcDate(String tzName) throws SException {
- // TimeZone tz = tzName != null ? TimeZone.getTimeZone(tzName) :
- // TimeZone.getDefault();
- // TimeZone.getTimeZone("GMT")
- public DcDate(TimeZone tz) throws RuntimeException {
-
- // based on http://javaalmanac.com/egs/java.util/GetAllZones.html?l=rel
-
- Calendar cal = new GregorianCalendar(tz);
- init(cal, tz);
- }
-
- public DcDate(Calendar cal) throws RuntimeException {
- init(cal, cal.getTimeZone());
- }
-
- private void init(Calendar cal, TimeZone tz) throws RuntimeException {
- // Get the number of hours from GMT
- int rawOffset = tz.getRawOffset();
- zoneOffset = rawOffset / (60 * 1000);
-
- instant = cal;
- // http://javaalmanac.com/egs/java.util/GetCurDate.html
- year = cal.get(Calendar.YEAR);
- month = cal.get(Calendar.MONTH) + 1; // 0=Jan, 1=Feb, ...
- day = cal.get(Calendar.DAY_OF_MONTH);
- hh = cal.get(Calendar.HOUR_OF_DAY); // 0..23
- mm = cal.get(Calendar.MINUTE); // 0..59
- ss = cal.get(Calendar.SECOND); // 0..59
- // int ms = cal.get(Calendar.MILLISECOND); // 0..999
- // date = cal.getTime();
- canonical = computeCanonical();
- }
-
- public DcDate(String dcDate) throws RuntimeException {
- // try {
- // synchronized(sdf) { //TODO REVISIT: SimpleFormat is not multi-thread
- // safe!
- // d = sdf.parse(dcDate);
- // }
- // } catch (ParseException e) {
- // throw new SException("could not parse dc:date "+dcDate+getCtx(pp),
- // e);
- // }
- // 2003-05-06T23:07:04Z
- // 2003-08-09T18:36:00-05:00
- // 1234567890123456789012345
- // 2004-02-02T19:09:46-05:00
- // 1997
- // 1997-07
- // 1997-07-16
- // 1997-07-16T19:20+01:00
- // 1997-07-16T19:20:30+01:00
- // 1997-07-16T19:20:30.45+01:00
- assert dcDate != null;
- // assert pp != null;
- canonical = dcDate;
- year = getInt(dcDate, 1, 4); // add min, max check for all getInt
- if (dcDate.length() == 4) {
- return;
- }
- check(dcDate, 5, '-');
- month = getInt(dcDate, 6, 2);
- if (dcDate.length() == 7) {
- return;
- }
- check(dcDate, 8, '-');
- day = getInt(dcDate, 9, 2);
- if (dcDate.length() == 10) {
- return;
- }
- check(dcDate, 11, 'T');
- hh = getInt(dcDate, 12, 2);
- check(dcDate, 14, ':');
- mm = getInt(dcDate, 15, 2);
- if (dcDate.length() == 16) {
- throw new RuntimeException("expected date formatted as YYYY-MM-DDThh:mm[:ss[.mmm]]TZD and not " + dcDate);
- }
- int pos = 17;
- char c17 = dcDate.charAt(pos - 1);
- if (c17 == ':') {
- check(dcDate, 17, ':');
- ss = getInt(dcDate, 18, 2);
- pos = 20;
- }
- char zoneIndicator = dcDate.charAt(pos - 1);
- if (zoneIndicator == '.') { // OK we have yet millliseocnds to parse
- // (and ignore ...)
- // Ex: 2004-04-13T11:53:15.4362784-04:00
- // eat digits
- char d;
- int oldPos = pos;
- do {
- d = dcDate.charAt(pos);
- ++pos;
- } while (d >= '0' && d <= '9');
- if (oldPos + 1 == pos) {
- throw new RuntimeException("expected date formtted as YYYY-MM-DDThh:mm[:ss[.s]]TZD and not " + dcDate);
-
- }
- zoneIndicator = d;
- int newPos = pos;
- decimalFraction = dcDate.substring(oldPos, newPos - 1);
- if (newPos - oldPos >= 3) {
- newPos = oldPos + 3;
- }
- int len = newPos - (oldPos + 1);
- int ii = getInt(dcDate, oldPos + 1, len);
- if (len == 1) {
- millisOffset = 100 * ii;
- } else if (len == 2) {
- millisOffset = 10 * ii;
- } else if (len == 3) {
- millisOffset = ii;
- }
- }
- if (zoneIndicator == 'Z') {
- // done
- } else if (zoneIndicator == '-' || zoneIndicator == '+') {
- int zoneHH = getInt(dcDate, pos + 1, 2);
- check(dcDate, pos + 3, ':');
- int zoneMM = getInt(dcDate, pos + 4, 2);
- zoneOffset = 60 * zoneHH + zoneMM;
- if (zoneIndicator == '-') {
- zoneOffset *= -1;
- }
- } else {
- throw new RuntimeException("unknown zone indicator " + zoneIndicator + " in " + dcDate);
- }
- // Get the number of hours from GMT
-
- // TimeZone tz = TimeZone.
- instant = new GregorianCalendar();
- int rawOffset = zoneOffset * 60 * 1000;
- instant.set(Calendar.ZONE_OFFSET, rawOffset);
- instant.set(Calendar.YEAR, year);
- instant.set(Calendar.MONTH, month - 1); // 0=Jan, 1=Feb, ...
- instant.set(Calendar.DAY_OF_MONTH, day);
- instant.set(Calendar.HOUR_OF_DAY, hh); // 0..23
- instant.set(Calendar.MINUTE, mm); // 0..59
- instant.set(Calendar.SECOND, ss); // 0..59
- instant.set(Calendar.MILLISECOND, millisOffset); // /0..999 ?
- instant.getTimeInMillis(); // full time in ms -- test?
- }
-
- public long getTimeInMillis() {
- return instant.getTimeInMillis();
- }
-
- public int getYear() {
- return year;
- }
-
- public int getMonth() {
- return month;
- }
-
- public int getDay() {
- return day;
- }
-
- public int getHour() {
- return hh;
- }
-
- public int getMinute() {
- return mm;
- }
-
- public int getSecond() {
- return ss;
- }
-
- public int getTimeZoneOffset() {
- return zoneOffset;
- }
-
- public String getDcDate() {
- return canonical;
- }
-
- public String getDecimalFraction() {
- return decimalFraction;
- }
-
- private String computeCanonical() {
- // 2003-08-09T18:36:00-05:00
- // 1234567890123456789012345
- StringBuffer sb = new StringBuffer();
- fill(sb, year, 4);
- if (month > 0) {
- sb.append('-');
- fill(sb, month, 2);
- if (day > 0) {
- sb.append('-');
- fill(sb, day, 2);
- if (hh > -1) {
- sb.append('T');
- fill(sb, hh, 2);
- sb.append(':');
- fill(sb, mm, 2);
- if (ss > -1) {
- sb.append(':');
- fill(sb, ss, 2);
- }
- if (decimalFraction != null) {
- sb.append('.');
- sb.append(decimalFraction);
- }
- if (zoneOffset == 0) {
- sb.append('Z');
- } else {
- int off = zoneOffset;
- if (zoneOffset > 0) {
- sb.append('+');
- } else {
- sb.append('-');
- off *= -1;
- }
- int zoneHH = off / 60;
- int zoneMM = off % 60;
- fill(sb, zoneHH, 2);
- sb.append(':');
- fill(sb, zoneMM, 2);
- }
- }
- }
- }
- return sb.toString();
- }
-
- public String toString() {
- return canonical;
- }
-
- public final static String LOCATION_PROPERTY = "http://xmlpull.org/v1/doc/properties.html#location";
-
- public static String printable(char ch) {
- return "'" + escape(ch) + "'";
- }
-
- public static String printable(String s) {
- return "\"" + escape(s) + "\"";
- }
-
- public static String escape(char ch) {
- if (ch == '\n') {
- return "\\n";
- } else if (ch == '\r') {
- return "\\r";
- } else if (ch == '\t') {
- return "\\t";
- } else if (ch == '\'') {
- return "\\'";
- }
- if (ch > 127 || ch < 32) {
- return "\\u" + Integer.toHexString((int) ch);
- }
- return "" + ch;
- }
-
- public static String escape(String s) {
- if (s == null) {
- return null;
- }
- final int sLen = s.length();
- StringBuffer buf = new StringBuffer(sLen + 10);
- for (int i = 0; i < sLen; ++i) {
- buf.append(escape(s.charAt(i)));
- }
- s = buf.toString();
- return s;
- }
-
- private static final int LOOKUP_10S[] = { 1, 10, 10 * 10, 10 * 100, 100 * 100 };
-
- public static void fill(StringBuffer sb, int value, int fields) {
- assert fields > 0;
- assert fields <= 4;
- assert value >= 0;
- int mm = LOOKUP_10S[fields];
- assert value < mm;
- // assert mm > 0
- // TODO: optimize it ...
- while (fields-- > 0) {
- mm /= 10;
- if (value >= mm) {
- sb.append((value / mm) % 10);
- // i /= 10;
- } else {
- sb.append('0');
- }
- }
-
- // String s = sb.toString();
- // assert s.toString().length == fields;
- // return s;
- }
-
- public static void check(String dcDate, int pos, char ch) {
- if (pos > dcDate.length()) {
- throw new RuntimeException("expected " + printable(ch) + " at position " + pos + " but " + dcDate
- + " is too short");
- }
- char c = dcDate.charAt(pos - 1);
- if (c != ch) {
- throw new RuntimeException("expected " + printable(ch) + " but got " + printable(c) + " in " + dcDate);
- }
- }
-
- public static int getInt(String dcDate, int pos, int len) throws RuntimeException {
- assert len > 0;
- int end = pos + len - 1;
- String s = dcDate.substring(pos - 1, end);
- try {
- int i = Integer.parseInt(s);
- return i;
- } catch (NumberFormatException e) {
- throw new RuntimeException("expected number for " + printable(s) + " in " + dcDate, e);
-
- }
- }
-
- /**
- * Take string and return string that has no spaces, only alpahnumerics, each word is capitalized (like WikiWords)
- * sometimes called CamelCase?!.
- */
- public static String getWikiTitle(String title) {
- StringBuffer sb = new StringBuffer();
- List<String> words = breakIntoWords(title);
- boolean start = true;
- for (Iterator<String> it = words.iterator(); it.hasNext();) {
- String word = it.next();
- boolean wordStart = true;
- for (int i = 0; i < word.length(); i++) {
- char c = word.charAt(i);
- if (Character.isLetterOrDigit(c)) {
- if (wordStart && !start) {
- sb.append(Character.toUpperCase(c));
- } else {
- sb.append(c);
- }
- wordStart = false;
- }
- }
- start = false;
- }
- return sb.toString();
- }
-
- public static List<String> breakIntoWords(String s) {
- List<String> words = new ArrayList<String>(s.length() / 5);
- boolean inWord = true;
- int wordStart = 0;
- for (int pos = 0; pos < s.length(); ++pos) {
- char ch = s.charAt(pos);
- boolean isWordSeparator = Character.isWhitespace(ch);
- if (ch == ',') {
- isWordSeparator = true;
- }
- if (ch == '.') {
- isWordSeparator = true;
- }
- if (isWordSeparator) {
- if (inWord) {
- words.add(s.substring(wordStart, pos));
- inWord = false;
- }
- } else {
- if (!inWord) {
- inWord = true;
- wordStart = pos;
- }
- }
- assert inWord == !isWordSeparator;
- }
- if (inWord) {
- words.add(s.substring(wordStart));
- }
- return words;
- }
-
- public static String makeTwoDigit(int oneOrTwoDigits) {
- if (oneOrTwoDigits < 0 || oneOrTwoDigits > 99) {
- throw new IllegalArgumentException();
- }
- if (oneOrTwoDigits < 10) {
- return "0" + oneOrTwoDigits;
- }
- return "" + oneOrTwoDigits;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewer.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewer.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewer.java
deleted file mode 100644
index def3f20..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewer.java
+++ /dev/null
@@ -1,82 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.wsmg.gui;
-
-import java.awt.Dimension;
-import java.awt.Toolkit;
-
-import javax.swing.SwingUtilities;
-import javax.swing.UIManager;
-
-public class NotificationViewer {
-
- boolean packFrame = false;
-
- /**
- * Construct and show the application.
- */
- public NotificationViewer() {
- NotificationViewerFrame frame = new NotificationViewerFrame();
- /*
- * Validate frames that have preset sizes Pack frames that have useful preferred size info, e.g. from their
- * layout
- */
- if (packFrame) {
- frame.pack();
- } else {
- frame.validate();
- }
-
- // Center the window
- Dimension screenSize = Toolkit.getDefaultToolkit().getScreenSize();
- Dimension frameSize = frame.getSize();
- if (frameSize.height > screenSize.height) {
- frameSize.height = screenSize.height;
- }
- if (frameSize.width > screenSize.width) {
- frameSize.width = screenSize.width;
- }
-
- frame.setLocation((screenSize.width - frameSize.width) / 2, (screenSize.height - frameSize.height) / 2);
- frame.setVisible(true);
- }
-
- /**
- * Application entry point.
- *
- * @param args
- * String[]
- */
- public static void main(String[] args) {
- SwingUtilities.invokeLater(new Runnable() {
- public void run() {
- try {
- UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
- } catch (Exception exception) {
- exception.printStackTrace();
- }
-
- new NotificationViewer();
- }
- });
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewerFrame.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewerFrame.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewerFrame.java
deleted file mode 100644
index c735fee..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewerFrame.java
+++ /dev/null
@@ -1,328 +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.gui;
-
-import java.awt.BorderLayout;
-import java.awt.Color;
-import java.awt.Dimension;
-import java.awt.Font;
-import java.awt.GridBagConstraints;
-import java.awt.GridBagLayout;
-import java.awt.Insets;
-import java.awt.event.ActionEvent;
-import java.awt.event.ActionListener;
-
-import javax.swing.BorderFactory;
-import javax.swing.JButton;
-import javax.swing.JFrame;
-import javax.swing.JLabel;
-import javax.swing.JOptionPane;
-import javax.swing.JPanel;
-import javax.swing.JScrollPane;
-import javax.swing.JTabbedPane;
-import javax.swing.JTextArea;
-import javax.swing.JTextField;
-import javax.swing.border.Border;
-
-import org.apache.airavata.wsmg.client.ConsumerServer;
-import org.apache.airavata.wsmg.client.WsntMsgBrokerClient;
-import org.apache.axis2.AxisFault;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class NotificationViewerFrame extends JFrame {
-
- private static final long serialVersionUID = -4924241323165353343L;
-
- private static final Logger logger = LoggerFactory.getLogger(NotificationViewerFrame.class);
-
- JPanel contentPane;
-
- BorderLayout borderLayout1 = new BorderLayout();
-
- JPanel jPanel1 = new JPanel();
-
- Border border1 = BorderFactory.createLineBorder(Color.gray, 2);
-
- JLabel jLabel1 = new JLabel();
-
- JButton jButtonStart = new JButton();
-
- JLabel jLabel2 = new JLabel();
-
- JTextField jTextBrokerUrl = new JTextField();
-
- JLabel jLabel3 = new JLabel();
-
- JTextField jTextPort = new JTextField();
-
- JLabel jLabel4 = new JLabel();
-
- JTextField jTextTopic = new JTextField();
-
- JTabbedPane jTabbedPane1 = new JTabbedPane();
-
- JScrollPane jScrollPane1 = new JScrollPane();
-
- JTextArea jTextAreaBrief = new JTextArea();
-
- JScrollPane jScrollPane2 = new JScrollPane();
-
- JTextArea jTextAreaWhole = new JTextArea();
-
- JButton jButtonClear = new JButton();
-
- ConsumerServer consumerServer = null;
-
- WsntMsgBrokerClient client;
-
- String subId = null;
-
- JButton jButtonStop = new JButton();
-
- GridBagLayout gridBagLayout1 = new GridBagLayout();
-
- public NotificationViewerFrame() {
- try {
- setDefaultCloseOperation(EXIT_ON_CLOSE);
- jbInit();
- } catch (Exception exception) {
- exception.printStackTrace();
- }
-
- client = new WsntMsgBrokerClient();
-
- }
-
- /**
- * Component initialization.
- *
- * @throws java.lang.Exception
- */
- private void jbInit() throws Exception {
- contentPane = (JPanel) getContentPane();
- contentPane.setLayout(borderLayout1);
- setSize(new Dimension(547, 429));
- setTitle("WS-Notification Viewer");
- jPanel1.setBackground(Color.white);
- jPanel1.setBorder(border1);
- jPanel1.setMaximumSize(new Dimension(180000, 180000));
- jPanel1.setLayout(gridBagLayout1);
- jLabel1.setFont(new java.awt.Font("Serif", Font.BOLD | Font.ITALIC, 28));
- jLabel1.setForeground(Color.blue);
- jLabel1.setText("WS-Notification Listener");
- jButtonStart.setToolTipText("Subscribe to the topic and start listening");
- jButtonStart.setText("Start");
- jButtonStart.addActionListener(new NotificationViewerFrame_jButton1_actionAdapter(this));
- jLabel2.setFont(new java.awt.Font("Dialog", Font.BOLD, 11));
- jLabel2.setText("BrokerURL");
- jTextBrokerUrl.setToolTipText("Enter Broker URL here.");
- jTextBrokerUrl.setText("http://localhost:8080/axis2/services/NotificationService");
- jLabel3.setFont(new java.awt.Font("Dialog", Font.BOLD, 11));
- jLabel3.setText("Listening Port");
- jTextPort.setToolTipText("Enter the port this listener will be listening to.");
- jTextPort.setText("19999");
- jLabel4.setFont(new java.awt.Font("Dialog", Font.BOLD, 11));
- jLabel4.setText("Topic");
- jTextTopic.setToolTipText("Enter the topic to subscribe.");
- jTextTopic.setText("topic");
- jTextAreaBrief.setToolTipText("Summary of the messages received.");
- jTextAreaBrief.setLineWrap(true);
- // jTextAreaWhole.setMinimumSize(new Dimension(490, 17));
- // jTextAreaWhole.setPreferredSize(new Dimension(490, 17));
- jTextAreaWhole.setToolTipText("Full content of the SOAP messages.");
- // jTextAreaWhole.setText("");
- jButtonClear.setToolTipText("Clear messages in the two message panes.");
- jButtonClear.setText("Clear Messages");
- jButtonClear.addActionListener(new NotificationViewerFrame_jButtonClear_actionAdapter(this));
- jButtonStop.setEnabled(false);
- jButtonStop.setToolTipText("Unsubscribe to the topic and stop listening.");
- jButtonStop.setText("Stop");
- jButtonStop.addActionListener(new NotificationViewerFrame_jButtonStop_actionAdapter(this));
- jScrollPane1.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
- jScrollPane1.setAutoscrolls(true);
- jScrollPane1.setToolTipText("Summary of the messages received.");
- jScrollPane2.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
- jScrollPane2.setAutoscrolls(true);
- jScrollPane2.setToolTipText("Full content of the SOAP messages.");
- jTabbedPane1.add(jScrollPane1, "Brief Messages");
- jTabbedPane1.add(jScrollPane2, "Whole Messages");
- jPanel1.add(jLabel1, new GridBagConstraints(1, 0, 2, 1, 0.0, 0.0, GridBagConstraints.WEST,
- GridBagConstraints.NONE, new Insets(7, 10, 0, 107), 20, -5));
- jPanel1.add(jButtonStop, new GridBagConstraints(2, 2, 1, 1, 0.0, 0.0, GridBagConstraints.CENTER,
- GridBagConstraints.NONE, new Insets(0, 48, 0, 80), 55, -4));
- jPanel1.add(jLabel4, new GridBagConstraints(0, 2, 1, 1, 0.0, 0.0, GridBagConstraints.WEST,
- GridBagConstraints.NONE, new Insets(0, 36, 0, 8), 43, 4));
- jPanel1.add(jLabel3, new GridBagConstraints(0, 3, 1, 1, 0.0, 0.0, GridBagConstraints.WEST,
- GridBagConstraints.NONE, new Insets(0, 36, 0, 0), 1, 4));
- jPanel1.add(jTextPort, new GridBagConstraints(1, 3, 1, 1, 1.0, 0.0, GridBagConstraints.WEST,
- GridBagConstraints.HORIZONTAL, new Insets(7, 0, 0, 0), 144, -1));
- jPanel1.add(jButtonClear, new GridBagConstraints(2, 3, 1, 1, 0.0, 0.0, GridBagConstraints.CENTER,
- GridBagConstraints.NONE, new Insets(0, 46, 0, 78), 3, -4));
- jPanel1.add(jTextTopic, new GridBagConstraints(1, 2, 1, 1, 1.0, 0.0, GridBagConstraints.SOUTHWEST,
- GridBagConstraints.HORIZONTAL, new Insets(0, 0, 0, 0), 149, -1));
- jPanel1.add(jTextBrokerUrl, new GridBagConstraints(1, 1, 1, 1, 1.0, 0.0, GridBagConstraints.NORTHWEST,
- GridBagConstraints.HORIZONTAL, new Insets(6, -1, 5, 1), 10, -1));
- jPanel1.add(jLabel2, new GridBagConstraints(0, 1, 1, 1, 0.0, 0.0, GridBagConstraints.NORTHWEST,
- GridBagConstraints.NONE, new Insets(6, 37, 5, 0), 21, 4));
- jPanel1.add(jButtonStart, new GridBagConstraints(2, 1, 1, 1, 0.0, 0.0, GridBagConstraints.CENTER,
- GridBagConstraints.NONE, new Insets(8, 47, 0, 79), 57, -4));
- jScrollPane2.getViewport().add(jTextAreaWhole);
- jScrollPane1.getViewport().add(jTextAreaBrief);
-
- jPanel1.add(jTabbedPane1, new GridBagConstraints(0, 4, 3, 1, 1.0, 1.0, GridBagConstraints.CENTER,
- GridBagConstraints.BOTH, new Insets(0, 18, 57, 30), 0, 206));
- contentPane.add(jPanel1, java.awt.BorderLayout.CENTER);
- }
-
- public void jButtonStart_actionPerformed(ActionEvent event) {
- // jLabel1.setForeground(new Color(255,0,0));
- String brokerUrl = jTextBrokerUrl.getText().trim();
- String topic = jTextTopic.getText();
-
- String listeningPort = jTextPort.getText();
-
- int port = -1;
-
- try {
- port = Integer.parseInt(listeningPort);
- } catch (NumberFormatException nfe) {
-
- JOptionPane.showMessageDialog(this, nfe, "invalid port specified", JOptionPane.ERROR_MESSAGE);
- return;
- }
-
- client.init(brokerUrl);// important
- // Create a handler to handle the notifications arrived
- WsntViewerConsumerNotificationHandler handler = new WsntViewerConsumerNotificationHandler(this);
-
- String consumerUrl = null;
-
- try {
- String[] eprs = client.startConsumerService(port, handler);
-
- if (eprs.length > 0) {
- consumerUrl = eprs[0];
- } else {
- throw new AxisFault("no consumer url given by wse client api");
- }
-
- } catch (Exception e) {
- JOptionPane.showMessageDialog(this, e, "Unable to start consumer service", JOptionPane.ERROR_MESSAGE);
- return;
- }
-
- try {
- subId = client.subscribe(consumerUrl, topic, null);
- } catch (Exception e) {
-
- JOptionPane.showMessageDialog(this, e, "Unable to subscribe to topic", JOptionPane.ERROR_MESSAGE);
-
- client.shutdownConsumerService();
- return;
- }
-
- jButtonStart.setEnabled(false);
- jTextBrokerUrl.setEnabled(false);
- jTextTopic.setEnabled(false);
- jTextPort.setEnabled(false);
- jButtonStop.setEnabled(true);
- jTextAreaBrief.append("Listener started...\n");
- jTextAreaWhole.append("Listener started...\n");
-
- }
-
- public void jButtonStop_actionPerformed(ActionEvent e) {
- if (subId != null) {
- try {
- client.init(jTextBrokerUrl.getText().trim());
- client.unSubscribe(subId);
- } catch (Exception e1) {
- JOptionPane.showMessageDialog(this, e, "Unable to unsubscribe from topic", JOptionPane.ERROR_MESSAGE);
- }// TODO: add with replyTo URL
- subId = null;
- }
-
- client.shutdownConsumerService();
-
- jButtonStop.setEnabled(false);
- jButtonStart.setEnabled(true);
- jTextBrokerUrl.setEnabled(true);
- jTextTopic.setEnabled(true);
- jTextPort.setEnabled(true);
- jTextAreaBrief.append("Listener stoped.\n");
- jTextAreaWhole.append("Listener stoped.\n");
-
- }
-
- public void addBriefMessage(String message) {
- jTextAreaBrief.append(message + "\n");
- jTextAreaBrief.selectAll();
- }
-
- public void addWholeMessage(String message) {
- jTextAreaWhole.append(message + "\n");
- jTextAreaWhole.selectAll();
- }
-
- public void jButtonClear_actionPerformed(ActionEvent e) {
- jTextAreaBrief.setText("");
- jTextAreaWhole.setText("");
- }
-}
-
-class NotificationViewerFrame_jButtonStop_actionAdapter implements ActionListener {
- private NotificationViewerFrame adaptee;
-
- NotificationViewerFrame_jButtonStop_actionAdapter(NotificationViewerFrame adaptee) {
- this.adaptee = adaptee;
- }
-
- public void actionPerformed(ActionEvent e) {
- adaptee.jButtonStop_actionPerformed(e);
- }
-}
-
-class NotificationViewerFrame_jButtonClear_actionAdapter implements ActionListener {
- private NotificationViewerFrame adaptee;
-
- NotificationViewerFrame_jButtonClear_actionAdapter(NotificationViewerFrame adaptee) {
- this.adaptee = adaptee;
- }
-
- public void actionPerformed(ActionEvent e) {
- adaptee.jButtonClear_actionPerformed(e);
- }
-}
-
-class NotificationViewerFrame_jButton1_actionAdapter implements ActionListener {
- private NotificationViewerFrame adaptee;
-
- NotificationViewerFrame_jButton1_actionAdapter(NotificationViewerFrame adaptee) {
- this.adaptee = adaptee;
- }
-
- public void actionPerformed(ActionEvent e) {
- adaptee.jButtonStart_actionPerformed(e);
-
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/README.txt
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/README.txt b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/README.txt
deleted file mode 100644
index 4244b93..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/README.txt
+++ /dev/null
@@ -1,15 +0,0 @@
-USING Notification Listener GUI.
-
-It is designed for Airavata project. The expected message XML schema in Airavata Workflow Management schema. It can also accept String messages.
-
- 1, Use ant to compile the package.
- 2, Then run
-source setenv.sh
-Or setenv.bat in Windows.
- to setup CLASSPATH. It looks better in Windows.
-
- 3, Then run:
- java wsnt.wsntviewapp.NotificationViewer
- to start the GUI.
-
-You need to enter Broker URL, topic and listening port.
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/WsntViewerConsumerNotificationHandler.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/WsntViewerConsumerNotificationHandler.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/WsntViewerConsumerNotificationHandler.java
deleted file mode 100644
index f1a4feb..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/gui/WsntViewerConsumerNotificationHandler.java
+++ /dev/null
@@ -1,114 +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.gui;
-
-import java.util.Iterator;
-
-import javax.xml.namespace.QName;
-import javax.xml.stream.XMLStreamException;
-
-import org.apache.airavata.wsmg.client.ConsumerNotificationHandler;
-import org.apache.airavata.wsmg.commons.NameSpaceConstants;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.soap.SOAPEnvelope;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class WsntViewerConsumerNotificationHandler implements ConsumerNotificationHandler {
- private final static Logger logger = LoggerFactory.getLogger(WsntViewerConsumerNotificationHandler.class);
-
- public NotificationViewerFrame frame = null;
-
- public WsntViewerConsumerNotificationHandler() {
- }
-
- public WsntViewerConsumerNotificationHandler(NotificationViewerFrame f) {
- this.frame = f;
- }
-
- public void handleNotification(SOAPEnvelope msgEnvelope) {
- logger.debug("*******lead message handler Received message********");
- logger.debug(msgEnvelope.toString());
- try {
- addBriefMsg(msgEnvelope);
- addWholeMsg(msgEnvelope);
- } catch (XMLStreamException e) {
- logger.error("invalid message received", e);
- throw new RuntimeException("invalid message recieved", e);
- }
- }
-
- private void addBriefMsg(SOAPEnvelope env) throws XMLStreamException {
-
- QName notify = new QName(NameSpaceConstants.WSNT_NS.getNamespaceURI(), "Notify",
- NameSpaceConstants.WSNT_NS.getPrefix());
-
- QName notifyMsg = new QName(NameSpaceConstants.WSNT_NS.getNamespaceURI(), "NotificationMessage",
- NameSpaceConstants.WSNT_NS.getPrefix());
-
- QName msg = new QName(NameSpaceConstants.WSNT_NS.getNamespaceURI(), "Message",
- NameSpaceConstants.WSNT_NS.getPrefix());
-
- if (env.getBody() == null) {
- throw new RuntimeException("invalid soap envelope - no soap body");
- }
-
- Iterator ite = env.getBody().getChildrenWithName(notify);
-
- if (!ite.hasNext()) {
- throw new RuntimeException(notify.getLocalPart() + " tag is not found");
- }
-
- OMElement ele = (OMElement) ite.next();
- ite = ele.getChildrenWithName(notifyMsg);
-
- if (!ite.hasNext()) {
- throw new RuntimeException(notifyMsg.getLocalPart() + " tag is not found");
- }
-
- ele = (OMElement) ite.next();
-
- ite = ele.getChildrenWithName(msg);
-
- if (!ite.hasNext()) {
- throw new RuntimeException(msg.getLocalPart() + " tags are not found");
- }
-
- while (ite.hasNext()) {
- ele = (OMElement) ite.next();
-
- if (ele.getFirstElement() != null) {
- frame.addBriefMessage(ele.getFirstElement().toString());
- } else {
- throw new RuntimeException("raw message is not found");
- }
-
- }
-
- }
-
- private void addWholeMsg(SOAPEnvelope envelope) throws XMLStreamException {
- frame.addWholeMessage(envelope.toStringWithConsume());
-
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/CreateMsgBox.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/CreateMsgBox.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/CreateMsgBox.java
deleted file mode 100644
index ae66997..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/CreateMsgBox.java
+++ /dev/null
@@ -1,118 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.wsmg.msgbox.client;
-
-import javax.xml.namespace.QName;
-
-import org.apache.airavata.wsmg.client.util.ClientUtil;
-import org.apache.airavata.wsmg.commons.MsgBoxQNameConstants;
-import org.apache.airavata.wsmg.commons.NameSpaceConstants;
-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.util.UUIDGenerator;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.client.Options;
-import org.apache.axis2.client.ServiceClient;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This class can be used to invoke createMsgBox operation of msgBoxService and returns the resultant messageBoxId as
- * EndpointReference
- */
-public class CreateMsgBox {
- private static final Logger logger = LoggerFactory.getLogger(CreateMsgBox.class);
- private final OMFactory factory = OMAbstractFactory.getOMFactory();
- protected String msgBoxEndPointReference;
- protected long timeoutInMilliSeconds;
- private String msgBoxId;
- private OMElement responseEl;
-
- public CreateMsgBox(String msgBoxLocation, long timeout) {
- this.msgBoxEndPointReference = msgBoxLocation;
- responseEl = OMAbstractFactory.getOMFactory().createOMElement(MsgBoxQNameConstants.MSG_BOXID_QNAME);
-
- timeoutInMilliSeconds = timeout;
- }
-
- public long getTimeoutInMilliSeconds() {
- return timeoutInMilliSeconds;
- }
-
- public void setTimeoutInMilliSeconds(long timeout) {
- timeoutInMilliSeconds = timeout;
- }
-
- public EndpointReference execute() throws AxisFault {
- ServiceClient serviceClient = createServiceClient();
- OMElement responseMessage = null;
- try {
- responseMessage = serviceClient.sendReceive(createMessageEl());
- } finally {
- serviceClient.cleanup();
- serviceClient.cleanupTransport();
- }
-
- if (responseMessage == null) {
- throw AxisFault.makeFault(new RuntimeException("no response recieved for subscription message"));
- }
- String response = responseMessage.getFirstElement().getText();
- this.responseEl.setText(response);
- this.msgBoxEndPointReference = ClientUtil.formatMessageBoxUrl(this.msgBoxEndPointReference, response);
- return new EndpointReference(this.msgBoxEndPointReference);
- }
-
- private OMElement createMessageEl() throws AxisFault {
- OMElement message = factory.createOMElement("createMsgBox", NameSpaceConstants.MSG_BOX);
- OMElement msgBoxId = factory.createOMElement("MsgBoxId", NameSpaceConstants.MSG_BOX);
- msgBoxId.setText("Create message box");
- message.addChild(msgBoxId);
- message.declareNamespace(NameSpaceConstants.MSG_BOX);
- return message;
- }
-
- private ServiceClient createServiceClient() throws AxisFault {
- String uuid = UUIDGenerator.getUUID();
- Options opts = new Options();
- opts.setProperty(org.apache.axis2.transport.http.HTTPConstants.CHUNKED, Boolean.FALSE);
- opts.setTo(new EndpointReference(this.msgBoxEndPointReference));
- opts.setMessageId(uuid);
- opts.setAction(NameSpaceConstants.MSG_BOX.getNamespaceURI() + "/" + "createMsgBox");
-
- opts.setTimeOutInMilliSeconds(getTimeoutInMilliSeconds());
- ServiceClient client = new ServiceClient();
- try {
- client.engageModule(WsmgCommonConstants.AXIS_MODULE_NAME_ADDRESSING);
- if (logger.isDebugEnabled())
- logger.debug("Addressing module engaged");
- } catch (AxisFault e) {
- if (logger.isDebugEnabled())
- logger.debug("Addressing module not engaged :" + e);
- }
- client.setOptions(opts);
- return client;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/DestroyMsgBox.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/DestroyMsgBox.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/DestroyMsgBox.java
deleted file mode 100644
index 057acdf..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/DestroyMsgBox.java
+++ /dev/null
@@ -1,120 +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.msgbox.client;
-
-import org.apache.airavata.wsmg.commons.NameSpaceConstants;
-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.util.UUIDGenerator;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.client.Options;
-import org.apache.axis2.client.ServiceClient;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This class can be used to invoke destroyMsgBox operation of msgBoxService and returns the resultant messageBoxId as
- * EndpointReference
- */
-public class DestroyMsgBox {
- private static final Logger logger = LoggerFactory.getLogger(DestroyMsgBox.class);
-
- private EndpointReference msgBoxEndPointReference = null;
- private long timeoutInMilliSeconds = 0;
- private String msgBoxId = null;
- private final OMFactory factory = OMAbstractFactory.getOMFactory();
-
- public DestroyMsgBox(EndpointReference msgBoxEpr, long timeout) throws AxisFault {
- this.msgBoxEndPointReference = msgBoxEpr;
- this.timeoutInMilliSeconds = timeout;
- String address = msgBoxEpr.getAddress();
- int biginIndex = address.indexOf("clientid");
- if (biginIndex != -1) {
- msgBoxId = address.substring(biginIndex + "clientid".length() + 1);
- } else {
- throw new AxisFault("Invalid Message Box EPR cannot find message box ID");
- }
- }
-
- public long getTimeoutInMilliSeconds() {
- return timeoutInMilliSeconds;
- }
-
- public void setTimeoutInMilliSeconds(long timeout) {
- timeoutInMilliSeconds = timeout;
- }
-
- public String execute() throws AxisFault {
- OMElement message = createMessageEl(this.msgBoxId);
- ServiceClient serviceClient = createServiceClient(message);
-
- OMElement responseMessage = null;
- try {
- responseMessage = serviceClient.sendReceive(message);
- } finally {
- serviceClient.cleanup();
- serviceClient.cleanupTransport();
- }
-
- responseMessage = serviceClient.sendReceive(message);
- if (responseMessage == null) {
- throw AxisFault.makeFault(new RuntimeException("no response recieved for subscription message"));
- }
- return responseMessage.getFirstElement().getText();
- }
-
- private OMElement createMessageEl(String msgboxid) throws AxisFault {
- OMElement message = factory.createOMElement("destroyMsgBox", NameSpaceConstants.MSG_BOX);
- OMElement msgBoxId = factory.createOMElement("MsgBoxId", NameSpaceConstants.MSG_BOX);
- msgBoxId.setText(msgboxid);
- message.addChild(msgBoxId);
- message.declareNamespace(NameSpaceConstants.MSG_BOX);
- return message;
- }
-
- private ServiceClient createServiceClient(OMElement message) throws AxisFault {
- String uuid = UUIDGenerator.getUUID();
- Options opts = new Options();
- opts.setProperty(org.apache.axis2.transport.http.HTTPConstants.CHUNKED, Boolean.FALSE);
- opts.setTo(msgBoxEndPointReference);
- opts.setMessageId(uuid);
- opts.setAction(message.getNamespace().getNamespaceURI() + "/" + message.getLocalName());
-
- opts.setTimeOutInMilliSeconds(getTimeoutInMilliSeconds());
-
- ServiceClient client = new ServiceClient();
- try {
- client.engageModule(WsmgCommonConstants.AXIS_MODULE_NAME_ADDRESSING);
- if (logger.isDebugEnabled())
- logger.debug("Addressing module engaged");
- } catch (AxisFault e) {
- if (logger.isDebugEnabled())
- logger.debug("Addressing module not engaged :" + e);
- }
-
- client.setOptions(opts);
- return client;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/MsgBoxClient.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/MsgBoxClient.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/MsgBoxClient.java
deleted file mode 100644
index 422c978..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/MsgBoxClient.java
+++ /dev/null
@@ -1,63 +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.msgbox.client;
-
-import java.rmi.RemoteException;
-import java.util.Iterator;
-
-import org.apache.axiom.om.OMElement;
-import org.apache.axis2.addressing.EndpointReference;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This is the client class to invoke MsgBoxService this is using four separate classes to invoke four methods
- * createMsgBox,destroyMsgBox,takeMessages and storeMessages operations of the service.
- */
-public class MsgBoxClient {
-
- int msgsAtOnce = 10;
- static Logger logger = LoggerFactory.getLogger(MsgBoxClient.class);
-
- public MsgBoxClient() {
- }
-
- public EndpointReference createMessageBox(String msgBoxLocation, long timeout) throws RemoteException {
- CreateMsgBox msgBox = new CreateMsgBox(msgBoxLocation, timeout);
- return msgBox.execute();
- }
-
- public String storeMessage(EndpointReference msgBoxEpr, long timeout, OMElement messageIn) throws RemoteException {
- StoreMessage strMsg = new StoreMessage(msgBoxEpr, timeout);
- return strMsg.execute(messageIn);
- }
-
- public Iterator<OMElement> takeMessagesFromMsgBox(EndpointReference msgBoxEpr, long timeout) throws RemoteException {
- TakeMessages takeMsgs = new TakeMessages(msgBoxEpr, timeout);
- return takeMsgs.execute();
- }
-
- public String deleteMsgBox(EndpointReference msgBoxEpr, long timeout) throws RemoteException {
- DestroyMsgBox destroyMsgBox = new DestroyMsgBox(msgBoxEpr, timeout);
- return destroyMsgBox.execute();
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/StoreMessage.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/StoreMessage.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/StoreMessage.java
deleted file mode 100644
index daa62ef..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/StoreMessage.java
+++ /dev/null
@@ -1,106 +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.msgbox.client;
-
-import org.apache.airavata.wsmg.commons.NameSpaceConstants;
-import org.apache.airavata.wsmg.commons.WsmgCommonConstants;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.util.UUIDGenerator;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.client.Options;
-import org.apache.axis2.client.ServiceClient;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This class can be used to invoke destroyMsgBox operation of msgBoxService and returns the resultant operation status
- * as EndpointReference
- */
-public class StoreMessage {
- private static final Logger logger = LoggerFactory.getLogger(StoreMessage.class);
-
- protected EndpointReference msgBoxEndPointReference;
- protected long timeoutInMilliSeconds;
-
- public StoreMessage(EndpointReference msgBoxEpr, long timeout) throws AxisFault {
- this.msgBoxEndPointReference = msgBoxEpr;
- this.timeoutInMilliSeconds = timeout;
- String address = msgBoxEpr.getAddress();
-
- /*
- * Validate
- */
- int biginIndex = address.indexOf("clientid");
- if (biginIndex == -1) {
- throw new AxisFault("Invalid Message Box EPR cannot find message box ID");
- }
- }
-
- public long getTimeoutInMilliSeconds() {
- return timeoutInMilliSeconds;
- }
-
- public void setTimeoutInMilliSeconds(long timeout) {
- timeoutInMilliSeconds = timeout;
- }
-
- public String execute(OMElement messageIn) throws AxisFault {
- ServiceClient serviceClient = createServiceClient();
-
- OMElement responseMessage = null;
-
- try {
- responseMessage = serviceClient.sendReceive(messageIn);
- } finally {
- serviceClient.cleanup();
- serviceClient.cleanupTransport();
- }
-
- if (responseMessage == null) {
- throw AxisFault.makeFault(new RuntimeException("no response recieved for subscription message"));
- }
- return responseMessage.getFirstElement().getText();
- }
-
- private ServiceClient createServiceClient() throws AxisFault {
- String uuid = UUIDGenerator.getUUID();
- Options opts = new Options();
- opts.setProperty(org.apache.axis2.transport.http.HTTPConstants.CHUNKED, Boolean.FALSE);
- opts.setTo(msgBoxEndPointReference);
- opts.setMessageId(uuid);
- opts.setAction(NameSpaceConstants.MSG_BOX.getNamespaceURI() + "/" + "storeMessages");
-
- opts.setTimeOutInMilliSeconds(getTimeoutInMilliSeconds());
- ServiceClient client = new ServiceClient();
- try {
- client.engageModule(WsmgCommonConstants.AXIS_MODULE_NAME_ADDRESSING);
- if (logger.isDebugEnabled())
- logger.debug("Addressing module engaged");
- } catch (AxisFault e) {
- if (logger.isDebugEnabled())
- logger.debug("Addressing module not engaged :" + e);
- }
- client.setOptions(opts);
- return client;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/TakeMessages.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/TakeMessages.java b/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/TakeMessages.java
deleted file mode 100644
index 8acf348..0000000
--- a/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/TakeMessages.java
+++ /dev/null
@@ -1,123 +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.msgbox.client;
-
-import java.util.Iterator;
-
-import org.apache.airavata.wsmg.commons.NameSpaceConstants;
-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.util.UUIDGenerator;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.client.Options;
-import org.apache.axis2.client.ServiceClient;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This class can be used to invoke takeMessages operation of msgBoxService and returns the resultant operation status
- *
- */
-public class TakeMessages {
- private static final Logger logger = LoggerFactory.getLogger(TakeMessages.class);
- private final OMFactory factory = OMAbstractFactory.getOMFactory();
- protected EndpointReference msgBoxEndPointReference;
- protected long timeoutInMilliSeconds;
- private String msgBoxId;
-
- public TakeMessages(EndpointReference msgBoxEpr, long timeout) throws AxisFault {
- this.msgBoxEndPointReference = msgBoxEpr;
- this.timeoutInMilliSeconds = timeout;
- String address = msgBoxEpr.getAddress();
- int biginIndex = address.indexOf("clientid");
- if (biginIndex != -1) {
- msgBoxId = address.substring(biginIndex + "clientid".length() + 1);
- } else {
- throw new AxisFault("Invalid Message Box EPR cannot find message box ID");
- }
- }
-
- public long getTimeoutInMilliSeconds() {
- return timeoutInMilliSeconds;
- }
-
- public void setTimeoutInMilliSeconds(long timeout) {
- timeoutInMilliSeconds = timeout;
- }
-
- public Iterator<OMElement> execute() throws AxisFault {
- OMElement message = createMessageEl(this.msgBoxId);
- ServiceClient serviceClient = createServiceClient(message);
-
- OMElement responseMessage = null;
- try {
- responseMessage = serviceClient.sendReceive(message);
-
- if (responseMessage == null) {
- throw AxisFault.makeFault(new RuntimeException("no response recieved for subscription message"));
- }
-
- responseMessage.build(); // free the input stream.
-
- } finally {
- serviceClient.cleanup();
- serviceClient.cleanupTransport();
- }
-
- return (Iterator<OMElement>) responseMessage.getFirstElement().getChildren();
- }
-
- private OMElement createMessageEl(String msgboxid) throws AxisFault {
- OMElement message = factory.createOMElement("takeMessages", NameSpaceConstants.MSG_BOX);
- OMElement msgBoxId = factory.createOMElement("MsgBoxId", NameSpaceConstants.MSG_BOX);
- msgBoxId.setText(msgboxid);
- message.addChild(msgBoxId);
- message.declareNamespace(NameSpaceConstants.MSG_BOX);
- return message;
- }
-
- private ServiceClient createServiceClient(OMElement message) throws AxisFault {
- String uuid = UUIDGenerator.getUUID();
- Options opts = new Options();
- opts.setProperty(org.apache.axis2.transport.http.HTTPConstants.CHUNKED, Boolean.FALSE);
- opts.setTo(msgBoxEndPointReference);
- opts.setMessageId(uuid);
- opts.setAction(message.getNamespace().getNamespaceURI() + "/" + message.getLocalName());
-
- opts.setTimeOutInMilliSeconds(getTimeoutInMilliSeconds());
- ServiceClient client = new ServiceClient();
- try {
- client.engageModule(WsmgCommonConstants.AXIS_MODULE_NAME_ADDRESSING);
- if (logger.isDebugEnabled())
- logger.debug("Addressing module engaged");
- } catch (AxisFault e) {
- if (logger.isDebugEnabled())
- logger.debug("Addressing module not engaged :" + e);
- }
-
- client.setOptions(opts);
- return client;
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/main/resources/amqp-routing-keys.xml
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/main/resources/amqp-routing-keys.xml b/modules/ws-messenger/client/src/main/resources/amqp-routing-keys.xml
deleted file mode 100644
index 74ef675..0000000
--- a/modules/ws-messenger/client/src/main/resources/amqp-routing-keys.xml
+++ /dev/null
@@ -1,40 +0,0 @@
-<?xml version='1.0' encoding='utf-8' ?>
-<!--Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file
- distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under
- the Apache License, Version 2.0 (theà "License"); you may not use this file except in compliance with the License. You may
- obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to
- in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
- ANY ~ KIND, either express or implied. See the License for the specific language governing permissions and limitations under
- the License. -->
-<routingKeys>
- <!-- Routing keys for "workflowInvoked" event -->
- <event name="workflowInvoked">
- <key name="primaryKey">
- <segment name="serviceID">notificationSource/@serviceID</segment>
- </key>
- </event>
- <!-- Routing keys for "invokingService" event -->
- <event name="invokingService">
- <key name="primaryKey">
- <segment name="serviceID">notificationSource/@serviceID</segment>
- </key>
- </event>
- <!-- Routing keys for "receivedResult" event -->
- <event name="receivedResult">
- <key name="primaryKey">
- <segment name="serviceID">notificationSource/@serviceID</segment>
- </key>
- </event>
- <!-- Routing keys for "sendingResult" event -->
- <event name="sendingResult">
- <key name="primaryKey">
- <segment name="serviceID">notificationSource/@serviceID</segment>
- </key>
- </event>
- <!-- Routing keys for "workflowTerminated" event -->
- <event name="workflowTerminated">
- <key name="primaryKey">
- <segment name="serviceID">notificationSource/@serviceID</segment>
- </key>
- </event>
-</routingKeys>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/airavata/blob/cab15715/modules/ws-messenger/client/src/test/java/org/apache/airavata/wsmg/client/amqp/BroadcastSubscriber.java
----------------------------------------------------------------------
diff --git a/modules/ws-messenger/client/src/test/java/org/apache/airavata/wsmg/client/amqp/BroadcastSubscriber.java b/modules/ws-messenger/client/src/test/java/org/apache/airavata/wsmg/client/amqp/BroadcastSubscriber.java
deleted file mode 100644
index 5dbeb1c..0000000
--- a/modules/ws-messenger/client/src/test/java/org/apache/airavata/wsmg/client/amqp/BroadcastSubscriber.java
+++ /dev/null
@@ -1,54 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.wsmg.client.amqp;
-
-import java.util.Properties;
-
-import org.apache.airavata.common.utils.ApplicationSettings;
-import org.apache.airavata.wsmg.client.amqp.rabbitmq.AMQPBroadcastReceiverImpl;
-
-public class BroadcastSubscriber {
- public static void main(String args[]) throws AMQPException {
- String host = ApplicationSettings.getSetting(AMQPUtil.CONFIG_AMQP_PROVIDER_HOST, "localhost");
- String port = ApplicationSettings.getSetting(AMQPUtil.CONFIG_AMQP_PROVIDER_PORT, "5672");
- String username = ApplicationSettings.getSetting(AMQPUtil.CONFIG_AMQP_PROVIDER_USERNAME, "guest");
- String password = ApplicationSettings.getSetting(AMQPUtil.CONFIG_AMQP_PROVIDER_PASSWORD, "guest");
-
- Properties properties = new Properties();
- properties.setProperty(AMQPUtil.CONFIG_AMQP_PROVIDER_HOST, host);
- properties.setProperty(AMQPUtil.CONFIG_AMQP_PROVIDER_PORT, port);
- properties.setProperty(AMQPUtil.CONFIG_AMQP_PROVIDER_USERNAME, username);
- properties.setProperty(AMQPUtil.CONFIG_AMQP_PROVIDER_PASSWORD, password);
-
- MessageConsumer consumer = new MessageConsumer();
- AMQPBroadcastReceiver receiver = new AMQPBroadcastReceiverImpl(properties, consumer);
- System.out.println("Waiting for broadcast messages : \n");
-
- receiver.Subscribe();
- }
-
- public static class MessageConsumer implements AMQPCallback {
- public void onMessage(String message) {
- System.out.println("Received : " + message);
- }
- }
-}