1 files changed, 13 insertions, 0 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
index d5100dc8e5..7fa028df29 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
+++ b/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();
+    }
 }