diff options
Diffstat (limited to 'qpid/java/broker/src/test/java/org/apache/qpid/server/txn/MockServerMessage.java')
-rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/txn/MockServerMessage.java | 11 |
1 files changed, 11 insertions, 0 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 422105e410..64c62fd029 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 @@ -46,56 +46,67 @@ class MockServerMessage implements ServerMessage this.persistent = persistent; } + @Override public boolean isPersistent() { return persistent; } + @Override public MessageReference 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; |