svn commit: r680023 - /synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSSender.java

[veithen]

Author: veithen
Date: Sat Jul 26 10:46:34 2008
New Revision: 680023

URL: http://svn.apache.org/viewvc?rev=680023&view=rev
Log:
JMSSender: corrected incorrect use of new String(byte[]) causing transmission 
of corrupted TextMessages

Modified:
    
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSSender.java

Modified: 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSSender.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSSender.java?rev=680023&r1=680022&r2=680023&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSSender.java
 (original)
+++ 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSSender.java
 Sat Jul 26 10:46:34 2008
@@ -39,6 +39,7 @@
 import javax.naming.NamingException;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
+import java.io.UnsupportedEncodingException;
 import java.util.*;
 
 /**
@@ -414,7 +415,11 @@
             } else {
                 message = session.createTextMessage();  // default
                 TextMessage txtMsg = (TextMessage) message;
-                txtMsg.setText(new String(baos.toByteArray()));
+                try {
+                    txtMsg.setText(new String(baos.toByteArray(), 
format.getCharSetEncoding()));
+                } catch (UnsupportedEncodingException ex) {
+                    handleException("Unsupported encoding " + 
format.getCharSetEncoding(), ex);
+                }
             }
             message.setStringProperty(BaseConstants.CONTENT_TYPE, contentType);