From 604a216da725da2770978756de763caa5c66e5c7 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 8 Nov 2007 14:05:38 +0000 Subject: Make standard exchanges durable Ensure flags are set correctly for recovered messages with no content git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593159 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/NullMessageStore.cpp | 21 +++++++++------------ 1 file changed, 9 insertions(+), 12 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 2190ff4086..2b7e8ff32d 100644 --- a/cpp/src/qpid/broker/NullMessageStore.cpp +++ b/cpp/src/qpid/broker/NullMessageStore.cpp @@ -53,18 +53,18 @@ bool NullMessageStore::init(const std::string& /*dir*/, const bool /*async*/, co void NullMessageStore::create(PersistableQueue& queue) { - QPID_LOG(info, "Can't create durable queue '" << queue.getName() << "'. Persistence not enabled."); + QPID_LOG(info, "Queue '" << queue.getName() + << "' will not be durable. Persistence not enabled."); } -void NullMessageStore::destroy(PersistableQueue& queue) +void NullMessageStore::destroy(PersistableQueue&) { - QPID_LOG(info, "Can't destroy durable queue '" << queue.getName() << "'. Persistence not enabled."); } void NullMessageStore::create(const PersistableExchange& exchange) { - QPID_LOG(info, "Can't create durable exchange '" - << exchange.getName() << "'. Persistence not enabled."); + QPID_LOG(info, "Exchange'" << exchange.getName() + << "' will not be durable. Persistence not enabled."); } void NullMessageStore::destroy(const PersistableExchange& ) @@ -86,12 +86,11 @@ void NullMessageStore::stage(PersistableMessage&) void NullMessageStore::destroy(PersistableMessage&) { - QPID_LOG(info, "No need to destroy staged message. Persistence not enabled."); } void NullMessageStore::appendContent(const PersistableMessage&, const string&) { - QPID_LOG(info, "Can't load content. Persistence not enabled."); + QPID_LOG(info, "Can't append content. Persistence not enabled."); } void NullMessageStore::loadContent(const PersistableMessage&, string&, uint64_t, uint32_t) @@ -102,18 +101,16 @@ void NullMessageStore::loadContent(const PersistableMessage&, string&, uint64_t, void NullMessageStore::enqueue(TransactionContext*, PersistableMessage& msg, const PersistableQueue& queue) { msg.enqueueComplete(); - QPID_LOG(info, "Can't enqueue message onto '" << queue.getName() << "'. Persistence not enabled."); + QPID_LOG(info, "Message is not durably recorded on '" << queue.getName() << "'. Persistence not enabled."); } -void NullMessageStore::dequeue(TransactionContext*, PersistableMessage& msg, const PersistableQueue& queue) +void NullMessageStore::dequeue(TransactionContext*, PersistableMessage& msg, const PersistableQueue&) { msg.dequeueComplete(); - QPID_LOG(info, "Can't dequeue message from '" << queue.getName() << "'. Persistence not enabled."); } -void NullMessageStore::flush(const qpid::broker::PersistableQueue& queue) +void NullMessageStore::flush(const qpid::broker::PersistableQueue&) { - QPID_LOG(info, "Can't flush. Persistence not enabled queue-" << queue.getName()); } u_int32_t NullMessageStore::outstandingQueueAIO(const PersistableQueue& ) -- cgit v1.2.1