try

tests/functional/replication/queueProcessor.js

@@ -873,7 +873,7 @@ describe('queue processor functional tests with mocking', () => {
             copyLocationResultsConsumer.subscribe();
             // it seems the consumer needs some extra time to start
             // consuming the first messages
-            return setTimeout(done, 5000);
+            return setTimeout(done, 2000);
         });
         s3mock = new S3Mock();
         httpServer = http.createServer(