From 7c966bd1fcb801e14e001237096470b9c7e87f1f Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Wed, 15 Aug 2007 18:13:02 +0000 Subject: async IO for broker store git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@566289 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/NullMessageStore.cpp | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) (limited to 'cpp/src/qpid/broker/NullMessageStore.cpp') diff --git a/cpp/src/qpid/broker/NullMessageStore.cpp b/cpp/src/qpid/broker/NullMessageStore.cpp index 35a2a45c1f..13f7dd3b9a 100644 --- a/cpp/src/qpid/broker/NullMessageStore.cpp +++ b/cpp/src/qpid/broker/NullMessageStore.cpp @@ -97,16 +97,23 @@ void NullMessageStore::loadContent(PersistableMessage&, string&, uint64_t, uint3 QPID_LOG(info, "Can't load content. Persistence not enabled."); } -void NullMessageStore::enqueue(TransactionContext*, PersistableMessage&, const PersistableQueue& queue) +void NullMessageStore::enqueue(TransactionContext*, PersistableMessage& msg, const PersistableQueue& queue) { + msg.enqueueComplete(); QPID_LOG(info, "Can't enqueue message onto '" << queue.getName() << "'. Persistence not enabled."); } -void NullMessageStore::dequeue(TransactionContext*, PersistableMessage&, const PersistableQueue& queue) +void NullMessageStore::dequeue(TransactionContext*, PersistableMessage& msg, const PersistableQueue& queue) { + msg.dequeueComplete(); QPID_LOG(info, "Can't dequeue message from '" << queue.getName() << "'. Persistence not enabled."); } +u_int32_t NullMessageStore::outstandingQueueAIO(const PersistableQueue& ) +{ + return 0; +} + std::auto_ptr NullMessageStore::begin() { return std::auto_ptr(); -- cgit v1.2.1