Browse Source

add new topics in acl list

Abhishek Kondur 2 years ago
parent
commit
21a07a8da7
1 changed files with 10 additions and 0 deletions
  1. 10 0
      mq/emqx.go

+ 10 - 0
mq/emqx.go

@@ -281,6 +281,16 @@ func CreateHostACL(hostID, serverName string) error {
 				Permission: "allow",
 				Action:     "all",
 			},
+			{
+				Topic:      fmt.Sprintf("peer/host/%s/%s", hostID, serverName),
+				Permission: "allow",
+				Action:     "all",
+			},
+			{
+				Topic:      fmt.Sprintf("fw/host/%s/%s", hostID, serverName),
+				Permission: "allow",
+				Action:     "all",
+			},
 			{
 				Topic:      fmt.Sprintf("dns/all/%s/%s", hostID, serverName),
 				Permission: "allow",