1 files changed, 14 insertions, 14 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/txn/MockServerMessage.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/txn/MockServerMessage.java
index 64c62fd029..790511017a 100644
--- a/qpid/java/broker/src/test/java/org/apache/qpid/server/txn/MockServerMessage.java
+++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/txn/MockServerMessage.java
@@ -31,10 +31,10 @@ import org.apache.qpid.server.message.ServerMessage;
 /**
  * Mock Server Message allowing its persistent flag to be controlled from test.
  */
-class MockServerMessage implements ServerMessage
+class MockServerMessage implements ServerMessage<MockServerMessage>
 {
     /**
-     * 
+     *
      */
     private final boolean persistent;
 
@@ -46,67 +46,67 @@ class MockServerMessage implements ServerMessage
         this.persistent = persistent;
     }
 
-    @Override
+
     public boolean isPersistent()
     {
         return persistent;
     }
 
-    @Override
-    public MessageReference newReference()
+
+    public MessageReference<MockServerMessage> newReference()
     {
         throw new NotImplementedException();
     }
 
-    @Override
+
     public boolean isImmediate()
     {
         throw new NotImplementedException();
     }
 
-    @Override
+
     public long getSize()
     {
         throw new NotImplementedException();
     }
 
-    @Override
+
     public SessionConfig getSessionConfig()
     {
         throw new NotImplementedException();
     }
 
-    @Override
+
     public String getRoutingKey()
     {
         throw new NotImplementedException();
     }
 
-    @Override
+
     public AMQMessageHeader getMessageHeader()
     {
         throw new NotImplementedException();
     }
 
-    @Override
+
     public long getExpiration()
     {
         throw new NotImplementedException();
     }
 
-    @Override
+
     public int getContent(ByteBuffer buf, int offset)
     {
         throw new NotImplementedException();
     }
 
-    @Override
+
     public long getArrivalTime()
     {
         throw new NotImplementedException();
     }
 
-    @Override
+
     public Long getMessageNumber()
     {
         return 0L;