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();
}
