summaryrefslogtreecommitdiff
path: root/java/systests/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java
diff options
context:
space:
mode:
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.java33
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;
+ }
}