WIP: support local transactipons

BUILD.md

@@ -23,7 +23,7 @@ This project can be built either with CMake, or with CMake executed by Bazel.
         -DProton_DIR=...
         -DProtonCpp_DIR=...
         -DENABLE_QPID_PROTON=ON
-        -DCMAKE_USER_C_FLAGS='-std=c++11'
+        -DCMAKE_USER_C_FLAGS='-std=c++17'
 
 ### Bazel command line
 

CMakeLists.txt

@@ -2,7 +2,7 @@ cmake_minimum_required(VERSION 3.20.0)
 project(cli-cpp)
 enable_language(CXX)
 
-set(CMAKE_CXX_STANDARD 11)
+set(CMAKE_CXX_STANDARD 17)
 set(CMAKE_CXX_STANDARD_REQUIRED ON)
 set(CMAKE_CXX_EXTENSIONS OFF)
 
@@ -97,7 +97,7 @@ if(NOT CMAKE_BUILD_TYPE)
 endif(NOT CMAKE_BUILD_TYPE)
 
 if (CMAKE_COMPILER_IS_GNUCXX)
-    set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++11")
+    set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++17")
 
     set(CMAKE_C_FLAGS "-Wall -Wshadow -fdiagnostics-color=auto" CACHE STRING
         "Flags used by the compiler during all build types." FORCE

src/api/qpid-proton/CMakeLists.txt

@@ -61,10 +61,14 @@ add_library(
     reactor/handler/CommonHandler.cpp
     reactor/handler/ConnectorHandler.cpp
     reactor/handler/SenderHandler.cpp
+    reactor/handler/TxSenderHandler.cpp
     reactor/handler/ReceiverHandler.cpp
+    reactor/handler/TxReceiverHandler.cpp
     reactor/ConnectingClient.cpp
     reactor/SendingClient.cpp
+    reactor/TxSendingClient.cpp
     reactor/ReceivingClient.cpp
+    reactor/TxReceivingClient.cpp
 )
 
 target_link_libraries(

src/api/qpid-proton/clients/aac3_receiver.cpp

@@ -1,17 +1,33 @@
 /*
- * aac1_sender.cpp
+ * aac3_sender.cpp
  *
  *  Created on: Apr 14, 2015
  *      Author: opiske
  */
-
 #include <reactor/ReceivingClient.h>
+#include <reactor/TxReceivingClient.h>
 
 using dtests::proton::reactor::ReceivingClient;
+using dtests::proton::reactor::TxReceivingClient;
 
 int main(int argc, char** argv)
 {
-    ReceivingClient client = ReceivingClient();
+    int i = 0;
+    bool tx_mode = false;
+    std::string tx_opt = "--tx-";
+    while (i < argc) {
+        if (std::string(argv[i]).rfind("--tx-", 0) == 0) { // pos=0 limits the search to the prefix
+            tx_mode = true;
+            break;
+        }
+        i++;
+    }
 
-    return client.run(argc, argv);
+    if (tx_mode) {
+        TxReceivingClient client = TxReceivingClient();
+        return client.run(argc, argv);
+    } else {
+        ReceivingClient client = ReceivingClient();
+        return client.run(argc, argv);
+    }
 }

src/api/qpid-proton/clients/aac3_sender.cpp

@@ -1,23 +1,33 @@
 /*
- * aac1_sender.cpp
+ * aac3_sender.cpp
  *
  *  Created on: Apr 14, 2015
  *      Author: opiske
  */
-#include <cstdlib>
-
 #include <reactor/SendingClient.h>
+#include <reactor/TxSendingClient.h>
 
 using dtests::proton::reactor::SendingClient;
+using dtests::proton::reactor::TxSendingClient;
 
 int main(int argc, char** argv)
 {
-    SendingClient client = SendingClient();
-
-    return client.run(argc, argv);
-
+    int i = 0;
+    bool tx_mode = false;
+    std::string tx_opt = "--tx-";
+    while (i < argc) {
+        if (std::string(argv[i]).rfind("--tx-", 0) == 0) { // pos=0 limits the search to the prefix
+	    tx_mode = true;
+	    break;
+        }
+        i++;
+    }
+
+    if (tx_mode) {
+        TxSendingClient client = TxSendingClient();
+        return client.run(argc, argv);
+    } else {
+        SendingClient client = SendingClient();
+        return client.run(argc, argv);
+    }
 }
-
-
-
-

src/api/qpid-proton/reactor/ReceivingClient.h

@@ -52,6 +52,7 @@ class ReceivingClient : public ModernClient {
   private:
     typedef ModernClient super;
 
+  protected:
     void setMessageOptions(const OptionsSetter &setter, message &msg) const;
 
 };

src/api/qpid-proton/reactor/SendingClient.h

@@ -47,6 +47,7 @@ class SendingClient : public ModernClient {
   private:
     typedef ModernClient super;
 
+  protected:
     void setMessageOptions(const OptionsSetter &setter, message &msg) const;
     bool nameVal(const string& in, string& name, string& value, string& separator) const;
     void setMessageProperty(message *msg, const string &property) const;