You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mi...@apache.org on 2009/03/04 01:50:33 UTC
svn commit: r749866 -
/ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/SoapExternalService.java
Author: midon
Date: Wed Mar 4 00:50:32 2009
New Revision: 749866
URL: http://svn.apache.org/viewvc?rev=749866&view=rev
Log:
ODE-533: better be careful
Modified:
ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/SoapExternalService.java
Modified: ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/SoapExternalService.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/SoapExternalService.java?rev=749866&r1=749865&r2=749866&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/SoapExternalService.java (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/SoapExternalService.java Wed Mar 4 00:50:32 2009
@@ -30,6 +30,7 @@
import org.apache.axis2.description.AxisService;
import org.apache.axis2.description.OutInAxisOperation;
import org.apache.axis2.description.OutOnlyAxisOperation;
+import org.apache.axis2.description.TransportOutDescription;
import org.apache.axis2.engine.AxisConfiguration;
import org.apache.axis2.transport.jms.JMSConstants;
import org.apache.axis2.transport.http.HTTPConstants;
@@ -193,7 +194,10 @@
}
} catch (Throwable t) {
// release the HTTP connection, we don't need it anymore
- mctx.getTransportOut().getSender().cleanup(mctx);
+ TransportOutDescription out = mctx.getTransportOut();
+ if (out != null && out.getSender() != null) {
+ out.getSender().cleanup(mctx);
+ }
String errmsg = "Error sending message (mex=" + odeMex + "): " + t.getMessage();
__log.error(errmsg, t);
replyWithFailure(mexId, MessageExchange.FailureType.COMMUNICATION_ERROR, errmsg);
@@ -483,9 +487,12 @@
String errmsg = "Unable to process response: " + ex.getMessage();
__log.error(errmsg, ex);
odeMex.replyWithFailure(FailureType.OTHER, errmsg, null);
- }finally{
- // make sure the HTTP connection is released to the pool!
- outMsgContext.getTransportOut().getSender().cleanup(outMsgContext);
+ } finally {
+ // make sure the HTTP connection is released to the pool!
+ TransportOutDescription out = outMsgContext.getTransportOut();
+ if (out != null && out.getSender() != null) {
+ out.getSender().cleanup(outMsgContext);
+ }
}
return null;
}