diff options
| -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) { |