1 files changed, 14 insertions, 0 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferMessage.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferMessage.java
index 38b647bfd1..5b08b9fb52 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferMessage.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferMessage.java
@@ -23,6 +23,7 @@ package org.apache.qpid.server.message;
 import org.apache.qpid.transport.*;
 
 import java.util.concurrent.atomic.AtomicLong;
+import java.nio.ByteBuffer;
 
 
 public class MessageTransferMessage implements InboundMessage, ServerMessage
@@ -96,4 +97,17 @@ public class MessageTransferMessage implements InboundMessage, ServerMessage
     {
         return _arrivalTime;
     }
+
+    public Header getHeader()
+    {
+        return _xfr.getHeader();
+
+    }
+
+    public ByteBuffer getBody()
+    {
+        return _xfr.getBody();
+    }
+
+
 }