diff options
author | Ted Ross <tross@apache.org> | 2008-10-20 19:03:26 +0000 |
---|---|---|
committer | Ted Ross <tross@apache.org> | 2008-10-20 19:03:26 +0000 |
commit | 80064052ca9f0fda855da693215b4d18e2abea0c (patch) | |
tree | 671e19aff9079b8fc9784c4ab11f67d0a9a76136 /cpp/src | |
parent | 7a592121b8a8404e431c4bb0f485f6bbde0db77f (diff) | |
download | qpid-python-80064052ca9f0fda855da693215b4d18e2abea0c.tar.gz |
Non-substantive changes. Removed tabs, neatened indentation, etc.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@706369 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
-rw-r--r-- | cpp/src/qpid/broker/Exchange.h | 177 |
1 files changed, 88 insertions, 89 deletions
diff --git a/cpp/src/qpid/broker/Exchange.h b/cpp/src/qpid/broker/Exchange.h index 154325e67f..1963ba1134 100644 --- a/cpp/src/qpid/broker/Exchange.h +++ b/cpp/src/qpid/broker/Exchange.h @@ -34,96 +34,95 @@ #include "qmf/org/apache/qpid/broker/Binding.h" namespace qpid { - namespace broker { - using std::string; - class ExchangeRegistry; - - class Exchange : public PersistableExchange, public management::Manageable { - private: - const string name; - const bool durable; - qpid::framing::FieldTable args; - boost::shared_ptr<Exchange> alternate; - uint32_t alternateUsers; - mutable uint64_t persistenceId; - - protected: - bool sequence; - mutable qpid::sys::Mutex sequenceLock; - uint64_t sequenceNo; - bool ive; - boost::intrusive_ptr<Message> lastMsg; - - class PreRoute{ - public: - PreRoute(Deliverable& msg, Exchange* _p); - ~PreRoute(); - private: - Exchange* parent; - }; +namespace broker { + +class ExchangeRegistry; + +class Exchange : public PersistableExchange, public management::Manageable { +private: + const std::string name; + const bool durable; + qpid::framing::FieldTable args; + boost::shared_ptr<Exchange> alternate; + uint32_t alternateUsers; + mutable uint64_t persistenceId; + +protected: + bool sequence; + mutable qpid::sys::Mutex sequenceLock; + uint64_t sequenceNo; + bool ive; + boost::intrusive_ptr<Message> lastMsg; + + class PreRoute{ + public: + PreRoute(Deliverable& msg, Exchange* _p); + ~PreRoute(); + private: + Exchange* parent; + }; - void routeIVE(); + void routeIVE(); - struct Binding : public management::Manageable { - typedef boost::shared_ptr<Binding> shared_ptr; - typedef std::vector<Binding::shared_ptr> vector; - - Queue::shared_ptr queue; - const std::string key; - const framing::FieldTable args; - qmf::org::apache::qpid::broker::Binding* mgmtBinding; - - Binding(const std::string& key, Queue::shared_ptr queue, Exchange* parent = 0, - framing::FieldTable args = framing::FieldTable ()); - ~Binding (); - management::ManagementObject* GetManagementObject () const; - }; - struct MatchQueue - { - const Queue::shared_ptr queue; - MatchQueue(Queue::shared_ptr q); - bool operator()(Exchange::Binding::shared_ptr b); - }; - - qmf::org::apache::qpid::broker::Exchange* mgmtExchange; - - public: - typedef boost::shared_ptr<Exchange> shared_ptr; - - explicit Exchange(const string& name, management::Manageable* parent = 0); - Exchange(const string& _name, bool _durable, const qpid::framing::FieldTable& _args, - management::Manageable* parent = 0); - virtual ~Exchange(); - - const string& getName() const { return name; } - bool isDurable() { return durable; } - qpid::framing::FieldTable& getArgs() { return args; } - - Exchange::shared_ptr getAlternate() { return alternate; } - void setAlternate(Exchange::shared_ptr _alternate) { alternate = _alternate; } - void incAlternateUsers() { alternateUsers++; } - void decAlternateUsers() { alternateUsers--; } - bool inUseAsAlternate() { return alternateUsers > 0; } - - virtual string getType() const = 0; - virtual bool bind(Queue::shared_ptr queue, const string& routingKey, const qpid::framing::FieldTable* args) = 0; - virtual bool unbind(Queue::shared_ptr queue, const string& routingKey, const qpid::framing::FieldTable* args) = 0; - virtual bool isBound(Queue::shared_ptr queue, const string* const routingKey, const qpid::framing::FieldTable* const args) = 0; - virtual void route(Deliverable& msg, const string& routingKey, const qpid::framing::FieldTable* args) = 0; - - //PersistableExchange: - void setPersistenceId(uint64_t id) const; - uint64_t getPersistenceId() const { return persistenceId; } - uint32_t encodedSize() const; - void encode(framing::Buffer& buffer) const; - - static Exchange::shared_ptr decode(ExchangeRegistry& exchanges, framing::Buffer& buffer); - - // Manageable entry points - management::ManagementObject* GetManagementObject(void) const; - }; - } -} - + struct Binding : public management::Manageable { + typedef boost::shared_ptr<Binding> shared_ptr; + typedef std::vector<Binding::shared_ptr> vector; + + Queue::shared_ptr queue; + const std::string key; + const framing::FieldTable args; + qmf::org::apache::qpid::broker::Binding* mgmtBinding; + + Binding(const std::string& key, Queue::shared_ptr queue, Exchange* parent = 0, + framing::FieldTable args = framing::FieldTable()); + ~Binding(); + management::ManagementObject* GetManagementObject() const; + }; + + struct MatchQueue { + const Queue::shared_ptr queue; + MatchQueue(Queue::shared_ptr q); + bool operator()(Exchange::Binding::shared_ptr b); + }; + + qmf::org::apache::qpid::broker::Exchange* mgmtExchange; + +public: + typedef boost::shared_ptr<Exchange> shared_ptr; + + explicit Exchange(const std::string& name, management::Manageable* parent = 0); + Exchange(const std::string& _name, bool _durable, const qpid::framing::FieldTable& _args, + management::Manageable* parent = 0); + virtual ~Exchange(); + + const std::string& getName() const { return name; } + bool isDurable() { return durable; } + qpid::framing::FieldTable& getArgs() { return args; } + + Exchange::shared_ptr getAlternate() { return alternate; } + void setAlternate(Exchange::shared_ptr _alternate) { alternate = _alternate; } + void incAlternateUsers() { alternateUsers++; } + void decAlternateUsers() { alternateUsers--; } + bool inUseAsAlternate() { return alternateUsers > 0; } + + virtual std::string getType() const = 0; + virtual bool bind(Queue::shared_ptr queue, const std::string& routingKey, const qpid::framing::FieldTable* args) = 0; + virtual bool unbind(Queue::shared_ptr queue, const std::string& routingKey, const qpid::framing::FieldTable* args) = 0; + virtual bool isBound(Queue::shared_ptr queue, const std::string* const routingKey, const qpid::framing::FieldTable* const args) = 0; + virtual void route(Deliverable& msg, const std::string& routingKey, const qpid::framing::FieldTable* args) = 0; + + //PersistableExchange: + void setPersistenceId(uint64_t id) const; + uint64_t getPersistenceId() const { return persistenceId; } + uint32_t encodedSize() const; + void encode(framing::Buffer& buffer) const; + + static Exchange::shared_ptr decode(ExchangeRegistry& exchanges, framing::Buffer& buffer); + + // Manageable entry points + management::ManagementObject* GetManagementObject(void) const; +}; + +}} #endif /*!_broker_Exchange.cpp_h*/ |