WIP: support local transactipons

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);
+    }
 }
-
-
-
-