From 14654e5360b72adf1704838b3820c7d1fc860e8e Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 6 Oct 2006 16:17:06 +0000 Subject: Decoupled routing from the channel and message classes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@453657 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/broker/inc/Message.h | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) (limited to 'cpp/broker/inc/Message.h') diff --git a/cpp/broker/inc/Message.h b/cpp/broker/inc/Message.h index 7a239adace..8b3321c2dc 100644 --- a/cpp/broker/inc/Message.h +++ b/cpp/broker/inc/Message.h @@ -29,14 +29,19 @@ namespace qpid { namespace broker { class ExchangeRegistry; - + + /** + * Represents an AMQP message, i.e. a header body, a list of + * content bodies and some details about the publication + * request. + */ class Message{ typedef std::vector content_list; typedef content_list::iterator content_iterator; const ConnectionToken* const publisher; - string exchange; - string routingKey; + const string exchange; + const string routingKey; const bool mandatory; const bool immediate; bool redelivered; @@ -44,8 +49,6 @@ namespace qpid { content_list content; u_int64_t contentSize(); - qpid::framing::BasicHeaderProperties* getHeaderProperties(); - public: typedef std::tr1::shared_ptr shared_ptr; @@ -64,10 +67,10 @@ namespace qpid { u_int32_t framesize); void redeliver(); - friend bool route(Message::shared_ptr& msg, ExchangeRegistry* registry); - + qpid::framing::BasicHeaderProperties* getHeaderProperties(); + const string& getRoutingKey() const { return routingKey; } + const string& getExchange() const { return exchange; } }; - bool route(Message::shared_ptr& msg, ExchangeRegistry* registry); } } -- cgit v1.2.1