Added error message to node registration

This commit is contained in:
2025-08-01 12:30:12 +02:00
parent 7191e57aea
commit 0bccad05f8

View File

@@ -237,9 +237,7 @@ class ChildRegistrationUtils {
if (this.mainClass?.upstreamReactor){ if (this.mainClass?.upstreamReactor){
this.mainClass.upstreamReactor = reactor; // Add reactor to the main class this.mainClass.upstreamReactor = reactor; // Add reactor to the main class
this.logger.info(`Upstream reactor registered successfully.`); this.logger.info(`Upstream reactor registered successfully.`);
} } else if (this.mainClass?.reactors) {
if (this.mainClass?.reactors) {
if (positionVsParent == "downstream") { if (positionVsParent == "downstream") {
this.mainClass.reactors[0] = reactor; this.mainClass.reactors[0] = reactor;
} }
@@ -247,6 +245,8 @@ class ChildRegistrationUtils {
this.mainClass.reactors[1] = reactor; this.mainClass.reactors[1] = reactor;
} }
this.logger.info(`Reactor registered successfully.`); this.logger.info(`Reactor registered successfully.`);
} else {
this.logger.error(`Reactor not registered!`)
} }
reactor.emitter.on("stateChange", (data) => { reactor.emitter.on("stateChange", (data) => {