Author: gordonsim
Date: 2007-09-14 11:13:38 -0400 (Fri, 14 Sep 2007)
New Revision: 920
Modified:
store/trunk/cpp/lib/BdbMessageStore.cpp
store/trunk/cpp/tests/persistence.py
Log:
Updated python test to allocate credit as subscriptions now start with none.
Fixed enqueue to set the async completion for more than the first queue.
Modified: store/trunk/cpp/lib/BdbMessageStore.cpp
===================================================================
--- store/trunk/cpp/lib/BdbMessageStore.cpp 2007-09-10 20:24:55 UTC (rev 919)
+++ store/trunk/cpp/lib/BdbMessageStore.cpp 2007-09-14 15:13:38 UTC (rev 920)
@@ -622,9 +622,10 @@
messageId = messageIdSequence.next();
store(&queue, txn->get(), key, msg);
msg.setPersistenceId(messageId);
- if (!usingJrnl())
- msg.enqueueComplete(); // set enqueued for ack
}
+ if (!usingJrnl()) {
+ msg.enqueueComplete(); // set enqueued for ack
+ }
if (!usingJrnl())
put(mappingDb, txn->get(), key, value);
Modified: store/trunk/cpp/tests/persistence.py
===================================================================
--- store/trunk/cpp/tests/persistence.py 2007-09-10 20:24:55 UTC (rev 919)
+++ store/trunk/cpp/tests/persistence.py 2007-09-14 15:13:38 UTC (rev 920)
@@ -117,6 +117,8 @@
channel.queue_delete(queue="queue-c")
channel.message_subscribe(destination="ctag",
queue="queue-a")
+ channel.message_flow(destination="ctag", unit=0, value=0xFFFFFFFF)
+ channel.message_flow(destination="ctag", unit=1, value=0xFFFFFFFF)
included = self.client.queue("ctag")
msg = included.get(timeout=1)
self.assertExpectedContent(msg, "Msg0004", "A_Message3")