diff options
Diffstat (limited to 'cpp/src/qpid/broker/RecoveredEnqueue.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/RecoveredEnqueue.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/RecoveredEnqueue.cpp b/cpp/src/qpid/broker/RecoveredEnqueue.cpp index 6d2eaee6c4..296d5194c0 100644 --- a/cpp/src/qpid/broker/RecoveredEnqueue.cpp +++ b/cpp/src/qpid/broker/RecoveredEnqueue.cpp @@ -22,10 +22,9 @@ #include "qpid/broker/Queue.h" #include "qpid/broker/RecoveredEnqueue.h" -using boost::intrusive_ptr; using namespace qpid::broker; -RecoveredEnqueue::RecoveredEnqueue(Queue::shared_ptr _queue, intrusive_ptr<Message> _msg) : queue(_queue), msg(_msg) +RecoveredEnqueue::RecoveredEnqueue(Queue::shared_ptr _queue, Message _msg) : queue(_queue), msg(_msg) { queue->recoverPrepared(msg); } @@ -36,7 +35,7 @@ bool RecoveredEnqueue::prepare(TransactionContext*) throw(){ } void RecoveredEnqueue::commit() throw(){ - queue->process(msg); + queue->enqueueCommited(msg); } void RecoveredEnqueue::rollback() throw(){ |