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 | d5f4f49951f7a8818cfbde421ef31ec695eb1bdb (patch) | |
| tree | c1b07e5cb82afd2672c47549e80edff1b9b4566c | |
| parent | 1b976cfb0c49d9352475fa1b45c36fff27f688ea (diff) | |
| download | qpid-python-d5f4f49951f7a8818cfbde421ef31ec695eb1bdb.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/qpid@655957 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | cpp/src/qpid/broker/Queue.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index 355ebdd81e..a8a7031757 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/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) { |