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.cpp7
1 files changed, 5 insertions, 2 deletions
diff --git a/cpp/lib/broker/BrokerMessageMessage.cpp b/cpp/lib/broker/BrokerMessageMessage.cpp
index 29186cc18e..153acb9ab5 100644
--- a/cpp/lib/broker/BrokerMessageMessage.cpp
+++ b/cpp/lib/broker/BrokerMessageMessage.cpp
@@ -94,8 +94,11 @@ bool MessageMessage::isComplete()
u_int64_t MessageMessage::contentSize() const
{
- THROW_QPID_ERROR(INTERNAL_ERROR, "Unfinished");
- return 0; // FIXME aconway 2007-02-05:
+ // FIXME astitcher 2007-2-7 only works for inline content
+ if (transfer->getBody().isInline())
+ return transfer->getBody().size();
+ else
+ THROW_QPID_ERROR(INTERNAL_ERROR, "Unfinished");
}
qpid::framing::BasicHeaderProperties* MessageMessage::getHeaderProperties()