You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by cc...@apache.org on 2007/09/08 02:14:25 UTC
svn commit: r573762 - in /incubator/qpid/trunk/qpid/cpp/src/qpid/broker:
MessageStore.h MessageStoreModule.cpp MessageStoreModule.h
NullMessageStore.cpp NullMessageStore.h PersistableQueue.h
Author: cctrieloff
Date: Fri Sep 7 17:14:24 2007
New Revision: 573762
URL: http://svn.apache.org/viewvc?rev=573762&view=rev
Log:
updates to be able to manage lifecycle of async store
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/PersistableQueue.h
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h?rev=573762&r1=573761&r2=573762&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h Fri Sep 7 17:14:24 2007
@@ -40,11 +40,11 @@
/**
* Record the existence of a durable queue
*/
- virtual void create(const PersistableQueue& queue) = 0;
+ virtual void create(PersistableQueue& queue) = 0;
/**
* Destroy a durable queue
*/
- virtual void destroy(const PersistableQueue& queue) = 0;
+ virtual void destroy(PersistableQueue& queue) = 0;
/**
* Record the existence of a durable exchange
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp?rev=573762&r1=573761&r2=573762&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp Fri Sep 7 17:14:24 2007
@@ -28,12 +28,12 @@
{
}
-void MessageStoreModule::create(const PersistableQueue& queue)
+void MessageStoreModule::create(PersistableQueue& queue)
{
store->create(queue);
}
-void MessageStoreModule::destroy(const PersistableQueue& queue)
+void MessageStoreModule::destroy(PersistableQueue& queue)
{
store->destroy(queue);
}
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h?rev=573762&r1=573761&r2=573762&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h Fri Sep 7 17:14:24 2007
@@ -45,8 +45,8 @@
void abort(TransactionContext& txn);
void collectPreparedXids(std::set<std::string>& xids);
- void create(const PersistableQueue& queue);
- void destroy(const PersistableQueue& queue);
+ void create(PersistableQueue& queue);
+ void destroy(PersistableQueue& queue);
void create(const PersistableExchange& exchange);
void destroy(const PersistableExchange& exchange);
void bind(const PersistableExchange& exchange, const PersistableQueue& queue,
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp?rev=573762&r1=573761&r2=573762&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp Fri Sep 7 17:14:24 2007
@@ -49,12 +49,12 @@
NullMessageStore::NullMessageStore(bool _warn) : warn(_warn){}
-void NullMessageStore::create(const PersistableQueue& queue)
+void NullMessageStore::create(PersistableQueue& queue)
{
QPID_LOG(info, "Can't create durable queue '" << queue.getName() << "'. Persistence not enabled.");
}
-void NullMessageStore::destroy(const PersistableQueue& queue)
+void NullMessageStore::destroy(PersistableQueue& queue)
{
QPID_LOG(info, "Can't destroy durable queue '" << queue.getName() << "'. Persistence not enabled.");
}
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h?rev=573762&r1=573761&r2=573762&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h Fri Sep 7 17:14:24 2007
@@ -45,8 +45,8 @@
virtual void abort(TransactionContext& txn);
virtual void collectPreparedXids(std::set<std::string>& xids);
- virtual void create(const PersistableQueue& queue);
- virtual void destroy(const PersistableQueue& queue);
+ virtual void create(PersistableQueue& queue);
+ virtual void destroy(PersistableQueue& queue);
virtual void create(const PersistableExchange& exchange);
virtual void destroy(const PersistableExchange& exchange);
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/PersistableQueue.h
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/PersistableQueue.h?rev=573762&r1=573761&r2=573762&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/PersistableQueue.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/PersistableQueue.h Fri Sep 7 17:14:24 2007
@@ -56,7 +56,7 @@
};
inline void setExternalQueueStore(ExternalQueueStore* inst) {externalQueueStore = inst;};
- inline ExternalQueueStore* getExternalQueueStore() {return externalQueueStore;};
+ inline ExternalQueueStore* getExternalQueueStore() const {return externalQueueStore;};
PersistableQueue():externalQueueStore(NULL){
};