diff options
Diffstat (limited to 'cpp/src/qpid/broker/BrokerMessageMessage.cpp')
-rw-r--r-- | cpp/src/qpid/broker/BrokerMessageMessage.cpp | 10 |
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)); |