Fixed bugs in connectReactor
This commit is contained in:
@@ -237,9 +237,8 @@ class ChildRegistrationUtils {
|
|||||||
this.logger.info(`Reactor registered successfully.`);
|
this.logger.info(`Reactor registered successfully.`);
|
||||||
|
|
||||||
reactor.emitter.on("stateChange", (data) => {
|
reactor.emitter.on("stateChange", (data) => {
|
||||||
this.mainClass.logger.debug(`State change of reactor detected: ${data}`);
|
this.mainClass.logger.debug(`State change of upstream reactor detected.`);
|
||||||
this.mainClass.setInflux = data;
|
this.mainClass.updateState(data);
|
||||||
this.mainClass.updateState(data.timestamp);
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user