Broker management of message acknowledgements now runs entirely off execution layer.

Flow control support.



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@564611 13f79535-47bb-0310-9956-ffa450edef68

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));