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){
};
