00001 #ifndef _broker_ExchangeRegistry_h
00002 #define _broker_ExchangeRegistry_h
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025 #include <map>
00026 #include "Exchange.h"
00027 #include "MessageStore.h"
00028 #include "qpid/framing/FieldTable.h"
00029 #include "qpid/sys/Monitor.h"
00030 #include "qpid/management/Manageable.h"
00031
00032 namespace qpid {
00033 namespace broker {
00034 struct UnknownExchangeTypeException{};
00035
00036 class ExchangeRegistry{
00037 typedef std::map<std::string, Exchange::shared_ptr> ExchangeMap;
00038 ExchangeMap exchanges;
00039 qpid::sys::RWlock lock;
00040 management::Manageable* parent;
00041 public:
00042 ExchangeRegistry () : parent(0) {}
00043 std::pair<Exchange::shared_ptr, bool> declare(const std::string& name, const std::string& type)
00044 throw(UnknownExchangeTypeException);
00045 std::pair<Exchange::shared_ptr, bool> declare(const std::string& name, const std::string& type,
00046 bool durable, const qpid::framing::FieldTable& args = framing::FieldTable())
00047 throw(UnknownExchangeTypeException);
00048 void destroy(const std::string& name);
00049 Exchange::shared_ptr get(const std::string& name);
00050 Exchange::shared_ptr getDefault();
00051
00055 void setParent (management::Manageable* _parent) { parent = _parent; }
00056 };
00057 }
00058 }
00059
00060
00061 #endif