diff --git a/src/configurations/quickjs/async-mqtt.js b/src/configurations/quickjs/async-mqtt.js index 636c4ebaaca9f1c2258b8ea444831a5c312eefe3..7c4a54a78534883b1f2d330768ff80f06a4790f4 100644 --- a/src/configurations/quickjs/async-mqtt.js +++ b/src/configurations/quickjs/async-mqtt.js @@ -33,13 +33,14 @@ class AsyncClient { host = "localhost", port = 9001, user = "admin", - password = "admin" + password = "admin", + clientId = "proto::interop-usp-controller" ) { this.client = new Paho.Client( host, port, "/mqtt", - "proto::interop-usp-controller" + clientId ); const opts = { userName: user, diff --git a/src/configurations/quickjs/index.ts b/src/configurations/quickjs/index.ts index 09e6e3068fccb1e4b430b200edbf45a9ff0e67d6..5b9f957fc98fb42f0efd2861a418c52c49c40f8f 100644 --- a/src/configurations/quickjs/index.ts +++ b/src/configurations/quickjs/index.ts @@ -21,7 +21,8 @@ const connectClient = async ( (options as HostConnectionOptions).host, (options as HostConnectionOptions).port, options.username, - options.password + options.password, + options.fromId || "proto::interop-usp-controller" ); const loadProtobuf = async (): Promise<Proto> => {