diff options
Diffstat (limited to 'java/systests/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java')
-rw-r--r-- | java/systests/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java | 33 |
1 files changed, 25 insertions, 8 deletions
diff --git a/java/systests/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java b/java/systests/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java index bc0a8a7d64..61edba36f8 100644 --- a/java/systests/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java +++ b/java/systests/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java @@ -20,11 +20,12 @@ */ package org.apache.qpid.server.store; -import org.apache.qpid.server.queue.AMQMessage; +import org.apache.commons.configuration.Configuration; +import org.apache.qpid.AMQException; +import org.apache.qpid.framing.ContentBody; import org.apache.qpid.server.queue.AMQQueue; +import org.apache.qpid.server.queue.MessageMetaData; import org.apache.qpid.server.queue.QueueRegistry; -import org.apache.qpid.AMQException; -import org.apache.commons.configuration.Configuration; import java.util.List; import java.util.concurrent.atomic.AtomicLong; @@ -47,11 +48,7 @@ public class SkeletonMessageStore implements MessageStore public void close() throws Exception { - } - - public void put(AMQMessage msg) - { - } + } public void removeMessage(long messageId) { @@ -99,4 +96,24 @@ public class SkeletonMessageStore implements MessageStore { return _messageId.getAndIncrement(); } + + public void storeContentBodyChunk(long messageId, int index, ContentBody contentBody) throws AMQException + { + + } + + public void storeMessageMetaData(long messageId, MessageMetaData messageMetaData) throws AMQException + { + + } + + public MessageMetaData getMessageMetaData(long messageId) throws AMQException + { + return null; + } + + public ContentBody getContentBodyChunk(long messageId, int index) throws AMQException + { + return null; + } } |