beemerReactor.js

const Rabbit = require("rabbit-driver");
class Beemer{
  constructor(store, rabbitConfig){
    this.store = store;
    this.loop();
    this.mq = new Rabbit(rabbitConfig);
  }
  loop(){
    // calls itself every 5 seconds to message the return from fetchState
    this.message(this.fetchState());
    this.timeout = setTimeout(loop, 5000)
  }
  fetchState(){
    // get health from state
    const state = this.store.getState();
    return {
      health: state.health,
      nodeid: state.uuid 
    };
  }
  message(state){
    // make this actually work
    this.mq.message(state);
  }
  stop(){
    clearTimeout(this.timeout);
  }
}

server_index.js.diff

diff --git a/supd2/server/index.js b/supd2/server/index.js
index 4a05412c0d..88cd09d015 100644
--- a/supd2/server/index.js
+++ b/supd2/server/index.js
@@ -72,6 +72,8 @@ module.exports = (program, version, config, schema, rw, overrides) => {
   let store;
 
   store = redux.createStore(require('./reducer').reducer());
+  const Beemer = require('./reactors/beemerReactor');
+  const beemInstance = new Beemer(store, rabbitConfig);
 
   // server config and compression for bundle size
   const options = { enableBrotli: true };
@@ -722,6 +724,7 @@ module.exports = (program, version, config, schema, rw, overrides) => {
 
   process.on('exit', () => {
     try {
+      beemInstance.stop();
       socketServer.close();
       kp.nuke();
       console.log('INFO: closing');
@@ -733,6 +736,7 @@ module.exports = (program, version, config, schema, rw, overrides) => {
   process.on('SIGINT', function (err) {
     // todo: logut store state and info about locks, etc
     kp.nuke();
+    beemInstance.stop();
     socketServer.close()
       .then(() =>
         process.exit(0));
@@ -740,6 +744,7 @@ module.exports = (program, version, config, schema, rw, overrides) => {
 
   process.once('SIGUSR2', function () {
     kp.nuke();
+    beemInstance.stop();
     socketServer.close()
       .then(() =>
         process.kill(process.pid, 'SIGUSR2'));
@@ -747,6 +752,7 @@ module.exports = (program, version, config, schema, rw, overrides) => {
 
   process.once('SIGTERM', function () {
     kp.nuke();
+    beemInstance.stop();
     socketServer.close()
       .then(() =>
         process.kill(process.pid, 'SIGUSR2'));