You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by as...@apache.org on 2008/01/03 17:49:34 UTC
svn commit: r608559 -
/webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportSender.java
Author: asankha
Date: Thu Jan 3 08:49:34 2008
New Revision: 608559
URL: http://svn.apache.org/viewvc?rev=608559&view=rev
Log:
fix SYNAPSE-219 by applying patch submitted by Andreas Veithen
Modified:
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportSender.java
Modified: webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportSender.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportSender.java?rev=608559&r1=608558&r2=608559&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportSender.java (original)
+++ webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportSender.java Thu Jan 3 08:49:34 2008
@@ -184,19 +184,23 @@
if (BaseConstants.DEFAULT_BINARY_WRAPPER.equals(firstChild.getQName())) {
try {
OutputStream os = responseFile.getContent().getOutputStream();
- OMNode omNode = firstChild.getFirstOMChild();
- if (omNode != null && omNode instanceof OMText) {
- Object dh = ((OMText) omNode).getDataHandler();
- if (dh != null && dh instanceof DataHandler) {
- ByteArrayOutputStream baos = new ByteArrayOutputStream();
- try {
- ((DataHandler) dh).writeTo(baos);
- } catch (IOException e) {
- handleException("Error serializing binary content of element : " +
- BaseConstants.DEFAULT_BINARY_WRAPPER, e);
+ try {
+ OMNode omNode = firstChild.getFirstOMChild();
+ if (omNode != null && omNode instanceof OMText) {
+ Object dh = ((OMText) omNode).getDataHandler();
+ if (dh != null && dh instanceof DataHandler) {
+ ByteArrayOutputStream baos = new ByteArrayOutputStream();
+ try {
+ ((DataHandler) dh).writeTo(baos);
+ } catch (IOException e) {
+ handleException("Error serializing binary content of element : " +
+ BaseConstants.DEFAULT_BINARY_WRAPPER, e);
+ }
+ os.write(baos.toByteArray());
}
- os.write(baos.toByteArray());
}
+ } finally {
+ os.close();
}
} catch (FileSystemException e) {
handleException("Error getting an output stream to file : " +
@@ -208,11 +212,14 @@
} else if (BaseConstants.DEFAULT_TEXT_WRAPPER.equals(firstChild.getQName())) {
try {
OutputStream os = responseFile.getContent().getOutputStream();
-
- if (firstChild instanceof OMSourcedElementImpl) {
- firstChild.serializeAndConsume(os);
- } else {
- os.write(firstChild.getText().getBytes());
+ try {
+ if (firstChild instanceof OMSourcedElementImpl) {
+ firstChild.serializeAndConsume(os);
+ } else {
+ os.write(firstChild.getText().getBytes());
+ }
+ } finally {
+ os.close();
}
} catch (FileSystemException e) {
handleException("Error getting an output stream to file : " +
@@ -247,8 +254,14 @@
try {
OutputStream os = responseFile.getContent().getOutputStream();
- messageFormatter.writeTo(msgContext, format, os, true);
+ try {
+ messageFormatter.writeTo(msgContext, format, os, true);
+ } finally {
+ os.close();
+ }
} catch (FileSystemException e) {
+ handleException("IO Error while creating response file : " + responseFile.getName(), e);
+ } catch (IOException e) {
handleException("IO Error while creating response file : " + responseFile.getName(), e);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org