diff options
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.java | 17 |
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; +} |