You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2012/10/01 22:49:33 UTC
svn commit: r1392584 - in
/airavata/trunk/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg:
client/ client/commons/ msgbox/client/
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();
}