summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2011-04-01 12:05:04 +0000
committerGordon Sim <gsim@apache.org>2011-04-01 12:05:04 +0000
commit1e56a289bfb74eb06f90bbd592fde6d9799b1df8 (patch)
treece8fb727cfe23460bb46a2fdacc13757cbf411d8
parent43e3b443abccff85d7c26370691ae33a48e2ce55 (diff)
downloadqpid-python-1e56a289bfb74eb06f90bbd592fde6d9799b1df8.tar.gz
QPID-3180: fix ring queues for the case where max size is 0 (implying infinite size)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1087669 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/cpp/src/qpid/broker/QueuePolicy.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/broker/QueuePolicy.cpp b/qpid/cpp/src/qpid/broker/QueuePolicy.cpp
index b39ea3614b..a93a6332fd 100644
--- a/qpid/cpp/src/qpid/broker/QueuePolicy.cpp
+++ b/qpid/cpp/src/qpid/broker/QueuePolicy.cpp
@@ -246,7 +246,7 @@ bool RingQueuePolicy::checkLimit(boost::intrusive_ptr<Message> m)
{
// If the message is bigger than the queue size, give up
- if (m->contentSize() > getMaxSize()) {
+ if (getMaxSize() && m->contentSize() > getMaxSize()) {
QPID_LOG(debug, "Message too large for ring queue " << name
<< " [" << *this << "] "
<< ": message size = " << m->contentSize() << " bytes"