Now Batch API looks for queues with jobs to consume at service initialization time

batch/index.js

@@ -13,7 +13,7 @@ var JobBackend = require('./job_backend');
 var Batch = require('./batch');
 
 module.exports = function batchFactory (metadataBackend) {
-    var jobSubscriber = new JobSubscriber(redis);
+    var jobSubscriber = new JobSubscriber(redis, metadataBackend);
     var jobQueuePool = new JobQueuePool(metadataBackend);
     var jobPublisher = new JobPublisher(redis);
     var jobQueue =  new JobQueue(metadataBackend);

batch/job_subscriber.js

@@ -1,13 +1,32 @@
 'use strict';
 
-function JobSubscriber(redis) {
+function JobSubscriber(redis, metadataBackend) {
     this.channel = 'batch:hosts';
     this.client = redis.createClient(global.settings.redis_port, global.settings.redis_host);
+    this.metadataBackend = metadataBackend;
+    this.db = 5;
+    this.redisPrefix = 'batch:queues:';
 }
 
 JobSubscriber.prototype.subscribe = function (onMessage) {
-    this.client.subscribe(this.channel);
-    this.client.on('message', onMessage);
+    var self = this;
+    var redisParams = [ this.redisPrefix + '*' ];
+
+    self.metadataBackend.redisCmd(self.db, 'KEYS', redisParams , function (err, queues) {
+        if (err) {
+            console.error(err);
+        }
+
+        if (queues) {
+            queues.forEach(function (queue) {
+                var host = queue.substr(queue.lastIndexOf(':') + 1);
+                onMessage(self.channel, host);
+            });
+        }
+
+        self.client.subscribe(self.channel);
+        self.client.on('message', onMessage);
+    });
 };
 
 JobSubscriber.prototype.unsubscribe = function () {

test/unit/batch/job_subscriber.js

@@ -23,8 +23,15 @@ describe('batch API job subscriber', function () {
                 self.redis.unsubscribeIsCalledWithValidArgs = isValidFirstArg;
             }
         };
+        this.metadataBackend = {
+            redisCmd: function () {
+                var callback = arguments[3];
 
-        this.jobSubscriber = new JobSubscriber(this.redis);
+                callback(null, []);
+            }
+        };
+
+        this.jobSubscriber = new JobSubscriber(this.redis, this.metadataBackend);
     });
 
     it('.subscribe() should listen for incoming messages', function () {