airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject svn commit: r1392584 - in /airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg: client/ client/commons/ msgbox/client/
Date Mon, 01 Oct 2012 20:49:33 GMT
Author: lahiru
Date: Mon Oct  1 20:49:32 2012
New Revision: 1392584

URL: http://svn.apache.org/viewvc?rev=1392584&view=rev
Log:
fixing axis2 anonService creation.

Modified:
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseCreateSubscription.java
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseMsgBrokerClient.java
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntCreatePublishReg.java
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntMsgBrokerClient.java
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsrfResourceStub.java
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/commons/NotificationProducer.java
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/CreateMsgBox.java
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/DestroyMsgBox.java
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/StoreMessage.java
    airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/TakeMessages.java

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseCreateSubscription.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseCreateSubscription.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseCreateSubscription.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseCreateSubscription.java
Mon Oct  1 20:49:32 2012
@@ -70,6 +70,7 @@ public class WseCreateSubscription {
 
         ServiceClient serviceClient = createServiceClient(message);
         OMElement responseMessage = serviceClient.sendReceive(message);
+        serviceClient.cleanup();
         serviceClient.cleanupTransport();
         if (responseMessage == null) {
             throw AxisFault.makeFault(new RuntimeException("no response recieved for subscription
message"));

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseMsgBrokerClient.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseMsgBrokerClient.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseMsgBrokerClient.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WseMsgBrokerClient.java
Mon Oct  1 20:49:32 2012
@@ -114,6 +114,7 @@ public class WseMsgBrokerClient extends 
                     xpathExpression, expireTime);
             ServiceClient serviceClient = configureServiceClientForSubscription(subscriptionMsg);
             OMElement responseMessage = serviceClient.sendReceive(subscriptionMsg);
+            serviceClient.cleanup();
             serviceClient.cleanupTransport();
 
             if (responseMessage == null) {
@@ -150,6 +151,7 @@ public class WseMsgBrokerClient extends 
             CommonRoutines.setHeaders(soapAction, brokerEndpointRef.getAddress(), client,
identifierEl);
 
             client.sendReceive(message);
+            client.cleanup();
             client.cleanupTransport();
 
         } catch (AxisFault e) {

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntCreatePublishReg.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntCreatePublishReg.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntCreatePublishReg.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntCreatePublishReg.java
Mon Oct  1 20:49:32 2012
@@ -75,6 +75,7 @@ public class WsntCreatePublishReg extend
         ServiceClient client = createServiceClient(message);
 
         OMElement responseMessage = client.sendReceive(message);
+        client.cleanup();
         client.cleanupTransport();
 
         OMElement publisherRegistrationRef = responseMessage.getFirstChildWithName(new QName(NameSpaceConstants.WSBR_NS

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntMsgBrokerClient.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntMsgBrokerClient.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntMsgBrokerClient.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsntMsgBrokerClient.java
Mon Oct  1 20:49:32 2012
@@ -109,6 +109,7 @@ public class WsntMsgBrokerClient extends
             ServiceClient client = createServiceClient(message);
 
             OMElement responseMessage = client.sendReceive(message);
+            client.cleanup();
             client.cleanupTransport();
 
             OMElement sr = responseMessage.getFirstChildWithName(new QName(

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsrfResourceStub.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsrfResourceStub.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsrfResourceStub.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/WsrfResourceStub.java
Mon Oct  1 20:49:32 2012
@@ -114,7 +114,14 @@ public class WsrfResourceStub {
         }
         client.setOptions(opts);
 
-        client.sendRobust(message);
+        try {
+            client.sendRobust(message);
+        } catch (AxisFault axisFault) {
+            axisFault.printStackTrace();  //To change body of catch statement use File |
Settings | File Templates.
+        }finally {
+            client.cleanup();
+            client.cleanupTransport();
+        }
     }
 
     public void setTerminationTime(Calendar cal) throws AxisFault {
@@ -156,7 +163,13 @@ public class WsrfResourceStub {
             client.addHeader(to);
         }
         client.setOptions(opts);
-        client.sendRobust(message);
+        try {
+            client.sendRobust(message);
+        } catch (AxisFault axisFault) {
+            axisFault.printStackTrace();  //To change body of catch statement use File |
Settings | File Templates.
+        }finally {
+            client.cleanupTransport();
+        }
 
     }
 

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/commons/NotificationProducer.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/commons/NotificationProducer.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/commons/NotificationProducer.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/commons/NotificationProducer.java
Mon Oct  1 20:49:32 2012
@@ -53,6 +53,7 @@ public class NotificationProducer {
         ServiceClient client = createServiceClient(type, notificationMessage, brokerLocationEPR,
timeout, null);
 
         OMElement ret = client.sendReceive(notificationMessage);
+        client.cleanup();
         client.cleanupTransport();
         return ret;
 
@@ -65,6 +66,7 @@ public class NotificationProducer {
                 topicExpressionEl);
 
         OMElement ret = client.sendReceive(notificationMessage);
+        client.cleanup();
         client.cleanupTransport();
         return ret;
 

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/CreateMsgBox.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/CreateMsgBox.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/CreateMsgBox.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/CreateMsgBox.java
Mon Oct  1 20:49:32 2012
@@ -71,6 +71,7 @@ public class CreateMsgBox {
         try {
             responseMessage = serviceClient.sendReceive(createMessageEl());
         } finally {
+            serviceClient.cleanup();
             serviceClient.cleanupTransport();
         }
 

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/DestroyMsgBox.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/DestroyMsgBox.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/DestroyMsgBox.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/DestroyMsgBox.java
Mon Oct  1 20:49:32 2012
@@ -74,6 +74,7 @@ public class DestroyMsgBox {
         try {
             responseMessage = serviceClient.sendReceive(message);
         } finally {
+            serviceClient.cleanup();
             serviceClient.cleanupTransport();
         }
 

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/StoreMessage.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/StoreMessage.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/StoreMessage.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/StoreMessage.java
Mon Oct  1 20:49:32 2012
@@ -72,6 +72,7 @@ public class StoreMessage {
         try {
             responseMessage = serviceClient.sendReceive(messageIn);
         } finally {
+            serviceClient.cleanup();
             serviceClient.cleanupTransport();
         }
 

Modified: airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/TakeMessages.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/TakeMessages.java?rev=1392584&r1=1392583&r2=1392584&view=diff
==============================================================================
--- airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/TakeMessages.java
(original)
+++ airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/msgbox/client/TakeMessages.java
Mon Oct  1 20:49:32 2012
@@ -82,6 +82,7 @@ public class TakeMessages {
             responseMessage.build(); // free the input stream.
 
         } finally {
+            serviceClient.cleanup();
             serviceClient.cleanupTransport();
         }
 



Mime
View raw message