diff options
Diffstat (limited to 'qpid/cpp/src/qpid/cluster/exp/MessageHandler.h')
-rw-r--r-- | qpid/cpp/src/qpid/cluster/exp/MessageHandler.h | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/qpid/cpp/src/qpid/cluster/exp/MessageHandler.h b/qpid/cpp/src/qpid/cluster/exp/MessageHandler.h index f1d3dc2726..ff5afefe27 100644 --- a/qpid/cpp/src/qpid/cluster/exp/MessageHandler.h +++ b/qpid/cpp/src/qpid/cluster/exp/MessageHandler.h @@ -26,6 +26,7 @@ #include "HandlerBase.h" #include "MessageBuilders.h" +#include "MessageHolder.h" #include "qpid/framing/AMQP_AllOperations.h" #include <boost/intrusive_ptr.hpp> #include <map> @@ -42,6 +43,8 @@ namespace cluster { class EventHandler; class BrokerContext; class Core; +class Group; +class MessageHolder; // FIXME aconway 2011-06-28: doesn't follow the same Handler/Replica/Context pattern as for queue. // Make this consistent. @@ -53,7 +56,7 @@ class MessageHandler : public framing::AMQP_AllOperations::ClusterMessageHandler public HandlerBase { public: - MessageHandler(EventHandler&, Core&); + MessageHandler(Group&, Core&); bool handle(const framing::AMQFrame&); @@ -67,8 +70,10 @@ class MessageHandler : public framing::AMQP_AllOperations::ClusterMessageHandler broker::Broker& broker; Core& core; - MessageBuilders messageBuilders; + MessageBuilders& messageBuilders; + MessageHolder& messageHolder; }; + }} // namespace qpid::cluster #endif /*!QPID_CLUSTER_MESSAGEHANDLER_H*/ |