summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/cluster/exp/MessageHandler.h
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/qpid/cluster/exp/MessageHandler.h')
-rw-r--r--qpid/cpp/src/qpid/cluster/exp/MessageHandler.h9
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*/