summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2007-08-25 16:17:29 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2007-08-25 16:17:29 +0000
commit91b71b5e76868d482a0889758acf0675c871d871 (patch)
treed3a45f54d83f8ea1a8b9e162d79d29691fff65dd
parent503601aee64ea1913d33795ada136817ad582b0c (diff)
downloadqpid-python-91b71b5e76868d482a0889758acf0675c871d871.tar.gz
Added a temp fix to overcome the ByteBuffer.array() problem
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@569695 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java13
1 files changed, 13 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java b/java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java
index ca81db88b3..b9be446db5 100644
--- a/java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java
+++ b/java/client/src/main/java/org/apache/qpidity/jms/message/BytesMessageImpl.java
@@ -836,12 +836,25 @@ public class BytesMessageImpl extends MessageImpl implements BytesMessage
{
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);
}
}