1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/tests/topic_publisher.cpp b/cpp/src/tests/topic_publisher.cpp
index c8f0d543ec..0f3406a1fe 100644
--- a/cpp/src/tests/topic_publisher.cpp
+++ b/cpp/src/tests/topic_publisher.cpp
@@ -171,7 +171,7 @@ int64_t Publisher::publish(int msgs, int listeners, int size){
     reportRequest.getHeaders().setString("TYPE", "REPORT_REQUEST");
     session.messageTransfer(arg::content=reportRequest, arg::destination="amq.topic", arg::acceptMode=1);
     if(transactional){
-        session.txCommit();
+        sync(session).txCommit();
     }    
     //wait for a response from each listener (TODO, could log these)
     for (int i = 0; i < listeners; i++) {
@@ -179,7 +179,7 @@ int64_t Publisher::publish(int msgs, int listeners, int size){
     }
 
     if(transactional){
-        session.txCommit();
+        sync(session).txCommit();
     }    
 
     AbsTime finish = now();