PROTON-2825: [C++ binding] Reject incoming transaction coordinator links

apache · May 29, 2024 · 813f87e · 813f87e
1 parent 54db24f
commit 813f87e
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/cpp/src/messaging_adapter.cpp b/cpp/src/messaging_adapter.cpp
@@ -273,7 +273,14 @@ void on_link_local_open(messaging_handler& handler, pn_event_t* event) {
 }
 
 void on_link_remote_open(messaging_handler& handler, pn_event_t* event) {
-    pn_link_t *lnk = pn_event_link(event);
+    auto lnk = pn_event_link(event);
+    // Currently don't implement (transaction) coordinator
+    if (pn_terminus_get_type(pn_link_remote_target(lnk))==PN_COORDINATOR) {
+      auto error = pn_link_condition(lnk);
+      pn_condition_set_name(error, "amqp:not-implemented");
+      pn_link_close(lnk);
+      return;
+    }
     if (pn_link_state(lnk) & PN_LOCAL_UNINIT) { // Incoming link
         // Copy source and target from remote end.
         pn_terminus_copy(pn_link_source(lnk), pn_link_remote_source(lnk));