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 | 12 |
1 files changed, 6 insertions, 6 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 index efd7264f96..4419a662dd 100644 --- 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 @@ -1,16 +1,16 @@ package org.apache.qpid.nclient.message; -import org.apache.qpid.AMQException; +import org.apache.qpid.nclient.core.AMQPException; public interface MessageStore { - public void removeMessage(String identifier); + public void removeMessage(String identifier) throws AMQPException; - public void storeContentBodyChunk(String identifier,byte[] contentBody) throws AMQException; + public void storeContentBodyChunk(String identifier,byte[] contentBody) throws AMQPException; - public void storeMessageMetaData(String identifier, MessageHeaders messageHeaders) throws AMQException; + public void storeMessageMetaData(String identifier, MessageHeaders messageHeaders) throws AMQPException; - public AMQPApplicationMessage getMessage(String identifier) throws AMQException; + public AMQPApplicationMessage getMessage(String identifier) throws AMQPException; - public void storeMessage(String identifier,AMQPApplicationMessage message)throws AMQException; + public void storeMessage(String identifier,AMQPApplicationMessage message)throws AMQPException; } |