summaryrefslogtreecommitdiff
path: root/cpp/lib/broker/MessageHandlerImpl.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/broker/MessageHandlerImpl.h')
-rw-r--r--cpp/lib/broker/MessageHandlerImpl.h13
1 files changed, 5 insertions, 8 deletions
diff --git a/cpp/lib/broker/MessageHandlerImpl.h b/cpp/lib/broker/MessageHandlerImpl.h
index 0fef45bb19..cb7e7e3126 100644
--- a/cpp/lib/broker/MessageHandlerImpl.h
+++ b/cpp/lib/broker/MessageHandlerImpl.h
@@ -24,7 +24,7 @@
#include "AMQP_ServerOperations.h"
#include "AMQP_ClientProxy.h"
#include "Reference.h"
-#include "BrokerChannel.h"
+#include "HandlerImpl.h"
namespace qpid {
namespace broker {
@@ -34,10 +34,11 @@ class Broker;
class MessageMessage;
class MessageHandlerImpl :
- public framing::AMQP_ServerOperations::MessageHandler
+ public framing::AMQP_ServerOperations::MessageHandler,
+ public HandlerImpl<framing::AMQP_ClientProxy::Message>
{
public:
- MessageHandlerImpl(Channel& ch, Connection& c, Broker& b);
+ MessageHandlerImpl(CoreRefs& parent);
void append(const framing::MethodContext&,
const std::string& reference,
@@ -116,14 +117,10 @@ class MessageHandlerImpl :
const std::string& transactionId,
const std::string& securityToken,
const framing::FieldTable& applicationHeaders,
- framing::Content body,
+ const framing::Content& body,
bool mandatory );
private:
- Channel& channel;
- Connection& connection;
- Broker& broker;
ReferenceRegistry references;
- framing::AMQP_ClientProxy::Message& client;
};
}} // namespace qpid::broker