added debugging utility method

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572750 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 13 insertions, 0 deletions

diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
index d5100dc8e5..7fa028df29 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
@@ -1092,4 +1092,17 @@ public class AMQMessage implements StorableMessage
             return rejected;
         }
     }
+
+    public String getBodyAsString()
+    {
+        StringBuilder b = new StringBuilder();
+        for (Iterator<ContentChunk> it = getContentBodyIterator(); it.hasNext(); )
+        {
+            ByteBuffer buf = it.next().getData();
+            byte[] bytes = new byte[buf.remaining()];
+            buf.duplicate().get(bytes);
+            b.append(new String(bytes));
+        }
+        return b.toString();
+    }
 }