summaryrefslogtreecommitdiff
path: root/java/newclient/src/main/java/org/apache/qpid/nclient/message/MessageStore.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/newclient/src/main/java/org/apache/qpid/nclient/message/MessageStore.java')
-rw-r--r--java/newclient/src/main/java/org/apache/qpid/nclient/message/MessageStore.java17
1 files changed, 17 insertions, 0 deletions
diff --git a/java/newclient/src/main/java/org/apache/qpid/nclient/message/MessageStore.java b/java/newclient/src/main/java/org/apache/qpid/nclient/message/MessageStore.java
new file mode 100644
index 0000000000..93eecdc0cc
--- /dev/null
+++ b/java/newclient/src/main/java/org/apache/qpid/nclient/message/MessageStore.java
@@ -0,0 +1,17 @@
+package org.apache.qpid.nclient.message;
+
+import org.apache.qpid.AMQException;
+import org.apache.qpid.client.message.MessageHeaders;
+
+public interface MessageStore {
+
+ public void removeMessage(String identifier);
+
+ public void storeContentBodyChunk(String identifier,byte[] contentBody) throws AMQException;
+
+ public void storeMessageMetaData(String identifier, MessageHeaders messageHeaders) throws AMQException;
+
+ public AMQPApplicationMessage getMessage(String identifier) throws AMQException;
+
+ public void storeMessage(String identifier,AMQPApplicationMessage message)throws AMQException;
+}