diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp b/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp index 9b2e31c925..607dc09fe8 100644 --- a/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp +++ b/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp @@ -112,7 +112,7 @@ void QueueFlowLimit::enqueued(const Message& msg) sys::Mutex::ScopedLock l(indexLock); ++count; - size += msg.getContentSize(); + size += msg.getMessageSize(); if (!flowStopped) { if (flowStopCount && count > flowStopCount) { @@ -150,7 +150,7 @@ void QueueFlowLimit::dequeued(const Message& msg) throw Exception(QPID_MSG("Flow limit count underflow on dequeue. Queue=" << queueName)); } - uint64_t _size = msg.getContentSize(); + uint64_t _size = msg.getMessageSize(); if (_size <= size) { size -= _size; } else { |