diff --git a/src/blockRepair.mjs b/src/blockRepair.mjs
index cd2615f..c234bd0 100644
--- a/src/blockRepair.mjs
+++ b/src/blockRepair.mjs
@@ -13,6 +13,7 @@ class BlockRepair {
         this.MASTERNODE_URL = nodeurl
         this.db = getDatabase()
         this.processor = getBlockProcessor(services, this.db)
+        this.running = false
     }
 
     run() {
@@ -41,9 +42,11 @@ class BlockRepair {
                 this.run()
             }
         } catch (e) {
+            this.running = false
             logger.error(e)
         }
         logger.complete("Repairing process ended.")
+        this.running = false
     }
 
     async blockProcessor(blockData) {
diff --git a/src/server.test.js b/src/server.test.js
index cf096a1..eac67a2 100644
--- a/src/server.test.js
+++ b/src/server.test.js
@@ -29,6 +29,33 @@ describe("Testing websocket server.", () => {
     clientSocket.disconnect();
   });
 
+  test("Subscribe to the new-state-changes-by-transaction event in tx hash room ", (done) => {
+    let data = newblock
+    clientSocket.once("new-block", (msg) => {
+      let message = JSON.parse(msg).message
+      expect(message).toEqual(data)
+    });
+    clientSocket.once("new-state-changes-by-transaction", (msg) => {
+      let message = JSON.parse(msg).message
+      expect(getType(message)).toBe('object')
+      expect(getType(message.tx_uid)).toBe('string')
+      expect(getType(message.blockNum)).toBe('number')
+      expect(message.blockNum).toBeDefined()
+      expect(message.timestamp).toBeDefined()
+      expect(message.affectedContractsList).toBeDefined()
+      expect(message.affectedVariablesList).toBeDefined()
+      expect(message.affectedRootKeysList).toBeDefined()
+      //expect(message.affectedRawKeysList).toBeDefined()
+      expect(message.state_changes_obj).toBeDefined()
+      //expect(message.txHash).toBeDefined()
+      expect(message.txInfo).toBeDefined()
+      done()
+    });
+    clientSocket.emit('join', data.processed.hash)
+    blockProcessor(data).catch((e) => { console.log(e) })
+  });
+
+
   test("Should get push notifications of new block after a new block was processed.", (done) => {
     let data = newblock[0]
     clientSocket.once("new-block", (msg) => {