wip

package.json

@@ -17,7 +17,7 @@
     "oplog_populator": "node extensions/oplogPopulator/OplogPopulatorTask.js",
     "mongo_queue_processor": "node extensions/mongoProcessor/mongoProcessorTask.js",
     "garbage_collector": "node extensions/gc/service.js",
-    "test": "mocha --recursive tests/unit --timeout 30000",
+    "test": "mocha --recursive tests/unit --timeout 60000",
     "cover:test": "nyc --clean --silent yarn run test && nyc report --report-dir ./coverage/test --reporter=lcov",
     "ft_test": "mocha --recursive $(find tests/functional -name '*.js') --timeout 30000",
     "ft_test:notification": "mocha --recursive $(find tests/functional/notification -name '*.js') --timeout 30000",

tests/functional/replication/queueProcessor.js

@@ -880,10 +880,16 @@ describe('queue processor functional tests with mocking', () => {
     after(done => {
         httpServer.close();
         async.parallel([
+            /* eslint-disable no-console */
             done => queueProcessorSF.stop(done),
+            console.log('queueProcessorSF stopped'),
             done => queueProcessorAzure.stop(done),
+            console.log('queueProcessorAzure stopped'),
             done => replicationStatusProcessor.stop(done),
+            console.log('replicationStatusProcessor stopped'),
             done => copyLocationResultsConsumer.close(done),
+            console.log('copyLocationResultsConsumer stopped'),
+            /* eslint-disable no-console */
         ], done);
     });