Skip to content

Commit 2b46a0a

Browse files
committed
fix: prod rmqtt acl add connect
1 parent 2b80ae7 commit 2b46a0a

File tree

2 files changed

+7
-3
lines changed

2 files changed

+7
-3
lines changed

agent/examples/publish_command.rs

+6-3
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,13 @@ async fn main() -> anyhow::Result<()> {
1515
"ls -ls".to_string()
1616
};
1717

18-
let config_path:PathBuf = "./config.yml".parse().unwrap();
19-
let publish_client_id = "test_web";
20-
let password:Option<String> = None;
2118
let username:Option<String> = None;
19+
let password:Option<String> = None;
20+
21+
let config_path:PathBuf = "./config.yml".parse().unwrap();
22+
let publish_client_id = "root";
23+
//let username:Option<String> = Some("".to_string());
24+
//let password:Option<String> = Some("".to_string());
2225

2326
let is_terminal = std::io::stdout().is_terminal();
2427

shell/prod/rmqtt/plugin/rmqtt-acl.toml

+1
Original file line numberDiff line numberDiff line change
@@ -12,5 +12,6 @@ rules = [
1212
["allow", { user = "timzaak", password = "timzaak", superuser = true }],
1313
# allow nodes to publish/subscribe shell command
1414
["allow", { user = "nodes", password ="nodes_password" }, "pubsub", ["cmd/%c", "cmd/%c/resp"]],
15+
["allow", { user = "nodes", password ="nodes_password" }, "connect"],
1516
["deny", "all"]
1617
]

0 commit comments

Comments
 (0)