summaryrefslogtreecommitdiff
path: root/cpp/lib/broker/BrokerMessageMessage.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/broker/BrokerMessageMessage.cpp')
-rw-r--r--cpp/lib/broker/BrokerMessageMessage.cpp33
1 files changed, 16 insertions, 17 deletions
diff --git a/cpp/lib/broker/BrokerMessageMessage.cpp b/cpp/lib/broker/BrokerMessageMessage.cpp
index 46f583b978..4168ff639c 100644
--- a/cpp/lib/broker/BrokerMessageMessage.cpp
+++ b/cpp/lib/broker/BrokerMessageMessage.cpp
@@ -22,29 +22,28 @@
using namespace qpid::broker;
-MessageMessage::MessageMessage(const qpid::framing::AMQMethodBody& _methodBody,
- const std::string& _exchange, const std::string& _routingKey,
- bool _mandatory, bool _immediate) :
- Message(_exchange, _routingKey, _mandatory, _immediate),
- methodBody(_methodBody)
+MessageMessage::MessageMessage(
+ const qpid::framing::AMQMethodBody::shared_ptr _methodBody,
+ const std::string& _exchange, const std::string& _routingKey,
+ bool _mandatory, bool _immediate) :
+ Message(_exchange, _routingKey, _mandatory, _immediate, _methodBody),
+ methodBody(_methodBody)
{
}
-void MessageMessage::deliver(qpid::framing::OutputHandler* /*out*/,
- int /*channel*/,
- const std::string& /*consumerTag*/,
- u_int64_t /*deliveryTag*/,
- u_int32_t /*framesize*/,
- qpid::framing::ProtocolVersion* /*version*/)
+void MessageMessage::deliver(
+ framing::ChannelAdapter& /*out*/,
+ const std::string& /*consumerTag*/,
+ u_int64_t /*deliveryTag*/,
+ u_int32_t /*framesize*/)
{
}
-void MessageMessage::sendGetOk(qpid::framing::OutputHandler* /*out*/,
- int /*channel*/,
- u_int32_t /*messageCount*/,
- u_int64_t /*deliveryTag*/,
- u_int32_t /*framesize*/,
- qpid::framing::ProtocolVersion* /*version*/)
+void MessageMessage::sendGetOk(
+ const framing::MethodContext& /*context*/,
+ u_int32_t /*messageCount*/,
+ u_int64_t /*deliveryTag*/,
+ u_int32_t /*framesize*/)
{
}