Merge pull request #402 from rodrigoaasm/DOJOT-95

[DOJOT-95] Update: actuation topic
dojot · Aug 1, 2022 · 9cfdcf0 · 9cfdcf0
2 parents 5a79345 + ff4a9ae
commit 9cfdcf0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/orchestrator/config.js b/orchestrator/config.js
@@ -92,6 +92,7 @@ let config = {
             subjects: {
                 tenancy: process.env.DOJOT_SUBJECT_TENANCY || "dojot.tenancy",
                 devices: process.env.DOJOT_SUBJECT_DEVICES || "dojot.device-manager.device",
+                actuation: process.env.DOJOT_SUBJECT_DEVICES_ACTUATION || "dojot.device-manager.device.actuation",
                 deviceData: process.env.DOJOT_SUBJECT_DEVICE_DATA || "device-data",
                 notification: process.env.DOJOT_SUBJECT_NOTIFICATIONS || "dojot.notifications",
                 ftp: process.env.DOJOT_SUBJECT_FTP || "dojot.ftp"

diff --git a/orchestrator/nodeManager.js b/orchestrator/nodeManager.js
@@ -211,7 +211,7 @@ class NodeManager {
             "event template in": new event_template_in(),
             "device template in": new template_in(),
             "actuate": new actuate(
-              new Publisher(kafkaMessenger, config.kafkaMessenger.dojot.subjects.devices, tenant)),
+              new Publisher(kafkaMessenger, config.kafkaMessenger.dojot.subjects.actuation, tenant)),
             "multi actuate": new multi_actuate(kafkaMessenger, config.kafkaMessenger.dojot.subjects.devices),
             "get context": new get_context(),
             "cron": new cron(),