diff options
| author | Gordon Sim <gsim@apache.org> | 2008-05-13 18:02:01 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-05-13 18:02:01 +0000 |
| commit | f4295ab286030329fd1cd70a1f1c02a4834c4040 (patch) | |
| tree | ee233bd09d6d797a029af38d751e81cea98c9fce /qpid/cpp | |
| parent | f63ff957673dd34621182a9fd6e7768f092c70c2 (diff) | |
| download | qpid-python-f4295ab286030329fd1cd70a1f1c02a4834c4040.tar.gz | |
Fail with exception if queue is not durable and configured policy is exceeded.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@655957 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Queue.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.cpp b/qpid/cpp/src/qpid/broker/Queue.cpp index 355ebdd81e..a8a7031757 100644 --- a/qpid/cpp/src/qpid/broker/Queue.cpp +++ b/qpid/cpp/src/qpid/broker/Queue.cpp @@ -429,8 +429,9 @@ void Queue::push(boost::intrusive_ptr<Message>& msg){ QPID_LOG(debug, "Message " << msg << " on " << name << " released from memory"); msg->releaseContent(store); } else { - QPID_LOG(warning, "Message " << msg << " on " << name + QPID_LOG(error, "Message " << msg << " on " << name << " exceeds the policy for the queue but can't be released from memory as the queue is not durable"); + throw ResourceLimitExceededException(QPID_MSG("Policy exceeded for " << name)); } } else { if (policyExceeded) { |