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);
}
}