You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2013/11/04 18:06:54 UTC
svn commit: r1538684 - /qpid/trunk/qpid/cpp/src/qpid/broker/PagedQueue.cpp
Author: gsim
Date: Mon Nov 4 17:06:54 2013
New Revision: 1538684
URL: http://svn.apache.org/r1538684
Log:
QPID-5290: fix exception thrown in PagedQueue
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/PagedQueue.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/PagedQueue.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/PagedQueue.cpp?rev=1538684&r1=1538683&r2=1538684&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/PagedQueue.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/PagedQueue.cpp Mon Nov 4 17:06:54 2013
@@ -23,6 +23,7 @@
#include "qpid/broker/QueueCursor.h"
#include "qpid/broker/Message.h"
#include "qpid/log/Statement.h"
+#include "qpid/framing/reply_exceptions.h"
#include <string.h>
namespace qpid {
@@ -103,7 +104,7 @@ bool PagedQueue::deleted(const QueueCurs
void PagedQueue::publish(const Message& added)
{
if (encodedSize(added) > pageSize) {
- throw qpid::Exception(QPID_MSG("Message is larger than page size for queue backed by " << path));
+ throw qpid::framing::PreconditionFailedException(QPID_MSG("Message is larger than page size for queue backed by " << path));
}
Used::reverse_iterator i = used.rbegin();
if (i != used.rend()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org