wip: initial version refactoring n9

rh-messaging · Dec 2, 2024 · 6e58ecb · 6e58ecb
1 parent ad9eae9
commit 6e58ecb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/src/api/qpid-proton/reactor/handler/TxReceiverHandler.cpp b/src/api/qpid-proton/reactor/handler/TxReceiverHandler.cpp
@@ -456,7 +456,7 @@ void TxReceiverHandler::on_message(delivery &d, message &m)
     }
 
     if (duration_time > 0 && duration_mode == "after-receive-action-tx-action") {
-        // TODO: Transactions are not supported yet
+        // TODO: not implemented yet
     }
 
     logger(debug) << "Process-reply-to: " << process_reply_to;

diff --git a/src/api/qpid-proton/reactor/handler/TxSenderHandler.cpp b/src/api/qpid-proton/reactor/handler/TxSenderHandler.cpp
@@ -94,7 +94,6 @@ TxSenderHandler::TxSenderHandler(
     confirmedSent(0),
     tx_action(tx_action),
     tx_endloop_action(tx_endloop_action),
-    // TODO whats this ?
     m(),
     timer_event(*this),
     interval(duration::IMMEDIATE)
@@ -220,7 +219,7 @@ void TxSenderHandler::send()
         }
 
         if (duration_time > 0 && duration_mode == "after-send-tx-action") {
-            // TODO: Transactions are not supported yet
+            // TODO: Not implemented yet
         }
 
         confirmedSent++;
@@ -341,8 +340,6 @@ void TxSenderHandler::on_transaction_committed(transaction t) {
     }
 }
 
-// TODO jak je to s temi override ?
-// void TxSenderHandler::on_transaction_aborted(transaction t) override {
 void TxSenderHandler::on_transaction_aborted(transaction t) {
     logger(trace) << "[on_transaction_aborted] Messages aborted";
     processed += current_batch;