1 files changed, 2 insertions, 7 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 af78042a63..1a230a2590 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
@@ -29,18 +29,14 @@ import java.nio.ByteBuffer;
 import java.lang.ref.WeakReference;
 
 
-public class MessageTransferMessage implements InboundMessage, ServerMessage<MessageTransferMessage>
+public class MessageTransferMessage extends AbstractServerMessageImpl implements InboundMessage
 {
-
-
     private StoredMessage<MessageMetaData_0_10> _storeMessage;
-
-
     private WeakReference<Session> _sessionRef;
 
     public MessageTransferMessage(StoredMessage<MessageMetaData_0_10> storeMessage, WeakReference<Session> sessionRef)
     {
-
+        super(storeMessage);
         _storeMessage = storeMessage;
         _sessionRef = sessionRef;
     }
@@ -145,5 +141,4 @@ public class MessageTransferMessage implements InboundMessage, ServerMessage<Mes
     {
         return _sessionRef == null ? null : (ServerSession) _sessionRef.get();
     }
-
 }