summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/BrokerMessageMessage.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/BrokerMessageMessage.cpp')
-rw-r--r--cpp/src/qpid/broker/BrokerMessageMessage.cpp10
1 files changed, 9 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/BrokerMessageMessage.cpp b/cpp/src/qpid/broker/BrokerMessageMessage.cpp
index 8e8eaf23f0..9ad27093bb 100644
--- a/cpp/src/qpid/broker/BrokerMessageMessage.cpp
+++ b/cpp/src/qpid/broker/BrokerMessageMessage.cpp
@@ -188,7 +188,7 @@ void MessageMessage::transferMessage(
}
-void MessageMessage::deliver(ChannelAdapter& channel, uint64_t, DeliveryToken::shared_ptr token, uint32_t framesize)
+void MessageMessage::deliver(ChannelAdapter& channel, DeliveryId, DeliveryToken::shared_ptr token, uint32_t framesize)
{
transferMessage(channel, shared_polymorphic_cast<MessageDeliveryToken>(token)->destination, framesize);
}
@@ -320,6 +320,14 @@ MessageMessage::ReferencePtr MessageMessage::getReference() const {
return reference;
}
+uint32_t MessageMessage::getRequiredCredit() const
+{
+ //TODO: change when encoding changes. Should be the payload of any
+ //header & body frames.
+ return transfer->size();
+}
+
+
DeliveryToken::shared_ptr MessageMessage::getToken(const std::string& destination)
{
return DeliveryToken::shared_ptr(new MessageDeliveryToken(destination));