1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/lib/broker/BrokerQueue.cpp b/cpp/lib/broker/BrokerQueue.cpp
index b0e1f20b01..a8c5343ca3 100644
--- a/cpp/lib/broker/BrokerQueue.cpp
+++ b/cpp/lib/broker/BrokerQueue.cpp
@@ -189,14 +189,14 @@ bool Queue::canAutoDelete() const{
 void Queue::enqueue(TransactionContext* ctxt, Message::shared_ptr& msg, const string * const xid)
 {
     if (msg->isPersistent() && store) {
-        store->enqueue(ctxt, msg, *this, xid);
+        store->enqueue(ctxt, msg.get(), *this, xid);
     }
 }
 
 void Queue::dequeue(TransactionContext* ctxt, Message::shared_ptr& msg, const string * const xid)
 {
     if (msg->isPersistent() && store) {
-        store->dequeue(ctxt, msg, *this, xid);
+        store->dequeue(ctxt, msg.get(), *this, xid);
     }
 }