diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2009-02-13 15:09:50 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2009-02-13 15:09:50 +0000 |
| commit | a8874f55a3b17ac94f38e6697bdb4bed72e7ee6c (patch) | |
| tree | cae9360e132d1379b581c704b0f86724e7d2433a /qpid/java/systests | |
| parent | c82b4f9475ecb2a62b6517f1b10fbefd69431600 (diff) | |
| download | qpid-python-a8874f55a3b17ac94f38e6697bdb4bed72e7ee6c.tar.gz | |
QPID-1630 : Updated MessageFactory to be responsible for assigning messagIDs. Several tests needed updating as they relied upon specified messageIDs.
Added a recovery mode to the MessageFactory where by new messages can have their ids specified but only as long as the new id is larger than the last one.
Recovered messages are always persistent.
Simplified a interfaces as a result of not requiring the messageID to be passed through.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@744140 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/systests')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java index 92a142e402..dd71b2d0da 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java @@ -251,14 +251,6 @@ public class SlowMessageStore implements MessageStore return b; } - public Long getNewMessageId() - { - doPreDelay("getNewMessageId"); - Long l = _realStore.getNewMessageId(); - doPostDelay("getNewMessageId"); - return l; - } - public void storeContentBodyChunk(StoreContext context, Long messageId, int index, ContentChunk contentBody, boolean lastContentBody) throws AMQException { doPreDelay("storeContentBodyChunk"); |