Author: asankha
Date: Tue Oct 9 05:30:52 2007
New Revision: 583140
URL: http://svn.apache.org/viewvc?rev=583140&view=rev
Log:
fix https://issues.apache.org/jira/browse/SYNAPSE-135
Modified:
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java
Modified:
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java?rev=583140&r1=583139&r2=583140&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java
(original)
+++
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java
Tue Oct 9 05:30:52 2007
@@ -631,19 +631,19 @@
if (message instanceof BytesMessage) {
BytesMessage bytesMessage = (BytesMessage) message;
- ByteBuffer msgBytes = ByteBuffer.allocate(1024);
+
try {
- while (true) {
- byte[] temp = new byte[1024];
- int read = bytesMessage.readBytes(temp);
- if (read > 0) {
- msgBytes.put(temp, 0, read);
- } else {
- msgBytes.flip();
- return msgBytes.array();
- }
- }
+ bytesMessage.reset();
+ byte[] buffer = new byte[1024];
+ ByteArrayOutputStream out = new ByteArrayOutputStream();
+
+ for (int bytesRead = bytesMessage.readBytes(buffer); bytesRead
!= -1;
+ bytesRead = bytesMessage.readBytes(buffer)) {
+ out.write(buffer, 0, bytesRead);
+ }
+ return out.toByteArray();
+
} catch (JMSException e) {
handleException("Error reading JMS binary message payload", e);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
