diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFMessage.java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFMessage.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFMessage.java b/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFMessage.java index 895ff643a2..3f6290dedb 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFMessage.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFMessage.java @@ -28,7 +28,7 @@ import org.apache.qpid.transport.codec.BBEncoder; import java.nio.ByteBuffer; import java.util.Set; -public class QMFMessage implements ServerMessage, InboundMessage, AMQMessageHeader +public class QMFMessage implements ServerMessage<QMFMessage>, InboundMessage, AMQMessageHeader { private ByteBuffer _content; @@ -154,7 +154,7 @@ public class QMFMessage implements ServerMessage, InboundMessage, AMQMessageHead return false; } - public MessageReference newReference() + public MessageReference<QMFMessage> newReference() { return new QMFMessageReference(this); } |