Author: rajith
Date: Sat Aug 25 09:17:29 2007
New Revision: 569695

URL: http://svn.apache.org/viewvc?rev=569695&view=rev
Log:
Added a temp fix to overcome the ByteBuffer.array() problem

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java?rev=569695&r1=569694&r2=569695&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java
 Sat Aug 25 09:17:29 2007
@@ -836,12 +836,25 @@
         {
             try
             {
+                /*
+                 * messageData.array() throws an UnsupportedOperationException
+                System.out.println("messageData Array : " 
+messageData.array().length);
+                
                 _dataIn = new DataInputStream(
                         new ByteArrayInputStream(messageData.array(), 
messageData.arrayOffset() + messageData.position()
                                 , messageData.remaining()));
+                */
+                
+                // temp hack
+                byte[] b = new byte[messageData.limit()];
+                messageData.get(b);
+                _dataIn = new DataInputStream(
+                        new ByteArrayInputStream(b));
+                                
             }
             catch (Exception e)
             {
+                e.printStackTrace();
                 throw new QpidException("Cannot retrieve data from message ", 
null, e);
             }
         }


Reply via email to