Skip to content

Commit

Permalink
Call ze_querying_subscriber_get after query sub is initialized
Browse files Browse the repository at this point in the history
Signed-off-by: Yadunund <[email protected]>
  • Loading branch information
Yadunund committed Jan 11, 2024
1 parent e03633e commit c0b8067
Showing 1 changed file with 8 additions and 0 deletions.
8 changes: 8 additions & 0 deletions rmw_zenoh_cpp/src/rmw_zenoh.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1321,6 +1321,14 @@ rmw_create_subscription(
RMW_SET_ERROR_MSG("unable to create zenoh subscription");
return nullptr;
}
// Call this method when a publisher with matching QoS is discovered since
// the published data could have been transmitted before the publisher was
// discovered.
ze_querying_subscriber_get(
z_loan(std::get<ze_owned_querying_subscriber_t>(sub_data->sub)),
z_loan(keyexpr),
NULL
);
}
// Create a regular subscriber for all other durability settings.
else {
Expand Down

0 comments on commit c0b8067

Please sign in to comment.