Skip to content

Commit 221e1ae

Browse files
committed
Admin space: change prefix to '@mqtt/'
1 parent 5b1fb47 commit 221e1ae

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

zenoh-plugin-mqtt/src/lib.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ macro_rules! ke_for_sure {
5252
}
5353

5454
lazy_static::lazy_static! {
55-
static ref KE_PREFIX_ADMIN_SPACE: &'static keyexpr = ke_for_sure!("@/service");
55+
static ref KE_PREFIX_ADMIN_SPACE: &'static keyexpr = ke_for_sure!("@mqtt");
5656
static ref ADMIN_SPACE_KE_VERSION: &'static keyexpr = ke_for_sure!("version");
5757
static ref ADMIN_SPACE_KE_CONFIG: &'static keyexpr = ke_for_sure!("config");
5858
}
@@ -134,8 +134,7 @@ async fn run(
134134
};
135135

136136
// declare admin space queryable
137-
let admin_keyexpr_prefix =
138-
*KE_PREFIX_ADMIN_SPACE / &zsession.zid().into_keyexpr() / ke_for_sure!("mqtt");
137+
let admin_keyexpr_prefix = *KE_PREFIX_ADMIN_SPACE / &zsession.zid().into_keyexpr();
139138
let admin_keyexpr_expr = (&admin_keyexpr_prefix) / ke_for_sure!("**");
140139
tracing::debug!("Declare admin space on {}", admin_keyexpr_expr);
141140
let config2 = config.clone();

0 commit comments

Comments
 (0)