Skip to content

Commit

Permalink
fixup: clarify special case for core endpoint links
Browse files Browse the repository at this point in the history
  • Loading branch information
kgiusti committed Nov 21, 2024
1 parent c0340e2 commit 8a9c1b7
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion src/adaptors/amqp/amqp_adaptor.c
Original file line number Diff line number Diff line change
Expand Up @@ -770,7 +770,10 @@ static bool AMQP_rx_handler(qd_router_t *router, qd_link_t *link)
break;
}

// Handle deliveries destined to a core endpoint.
// Handle deliveries destined to a core endpoint. Core endpoints use dedicated links that terminate in the core -
// meaning that deliveries arriving on these links are always consumed by the router and are not forwarded. Since
// these message are not routed we can skip all the following routing-related checks and simply hand the delivery
// directly to the core thread here.
//
if (qdr_link_is_core_endpoint(rlink)) {
log_link_message(conn, pn_link, msg);
Expand Down

0 comments on commit 8a9c1b7

Please sign in to comment.