diff options
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/qpid/broker/Queue.cpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index 4d9a7f2a37..5e806699de 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/cpp/src/qpid/broker/Queue.cpp @@ -835,7 +835,12 @@ bool Queue::enqueue(TransactionContext* ctxt, Message& msg) boost::intrusive_ptr<PersistableMessage> pmsg = msg.getPersistentContext(); assert(pmsg); pmsg->enqueueAsync(shared_from_this(), store); - store->enqueue(ctxt, pmsg, *this); + try { + store->enqueue(ctxt, pmsg, *this); + } catch (...) { + enqueueAborted(msg); + throw; + } } return true; } |