diff options
Diffstat (limited to 'cpp/lib/broker/MessageStoreModule.cpp')
| -rw-r--r-- | cpp/lib/broker/MessageStoreModule.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/lib/broker/MessageStoreModule.cpp b/cpp/lib/broker/MessageStoreModule.cpp index 1952786014..ccc5501379 100644 --- a/cpp/lib/broker/MessageStoreModule.cpp +++ b/cpp/lib/broker/MessageStoreModule.cpp @@ -73,6 +73,11 @@ void MessageStoreModule::dequeue(TransactionContext* ctxt, Message* const msg, c store->dequeue(ctxt, msg, queue, xid); } +void MessageStoreModule::prepared(const string * const xid) +{ + store->prepared(xid); +} + void MessageStoreModule::committed(const string * const xid) { store->committed(xid); |