diff --git a/io/zenoh-transport/src/unicast/establishment/accept.rs b/io/zenoh-transport/src/unicast/establishment/accept.rs index ae818716bc..b9de27c076 100644 --- a/io/zenoh-transport/src/unicast/establishment/accept.rs +++ b/io/zenoh-transport/src/unicast/establishment/accept.rs @@ -786,7 +786,11 @@ pub(crate) async fn accept_link( is_compression: state.link.ext_compression.is_compression(), }, priorities: state.transport.ext_qos.priorities(), - reliability: Reliability::from(link.link.is_reliable()), + reliability: state + .transport + .ext_qos + .reliability() + .unwrap_or_else(|| Reliability::from(link.link.is_reliable())), }; let a_link = link.reconfigure(a_config); let s_link = format!("{:?}", a_link); diff --git a/io/zenoh-transport/src/unicast/establishment/open.rs b/io/zenoh-transport/src/unicast/establishment/open.rs index 5ec16b4ed8..b231210c0a 100644 --- a/io/zenoh-transport/src/unicast/establishment/open.rs +++ b/io/zenoh-transport/src/unicast/establishment/open.rs @@ -671,7 +671,11 @@ pub(crate) async fn open_link( is_compression: state.link.ext_compression.is_compression(), }, priorities: state.transport.ext_qos.priorities(), - reliability: Reliability::from(link.link.is_reliable()), + reliability: state + .transport + .ext_qos + .reliability() + .unwrap_or_else(|| Reliability::from(link.link.is_reliable())), }; let o_link = link.reconfigure(o_config); let s_link = format!("{:?}", o_link);