Commit Graph

3 Commits

Author SHA1 Message Date
Raul Ochoa
ea9454d87c Add test to validate old jobs will get discovered 2017-04-04 15:42:34 +02:00
Daniel García Aubert
25a291bb38 Improve waek assertion 2017-04-04 09:50:45 +02:00
Daniel García Aubert
36d5dc1719 Queue seeker refactor:
- Extract from job subcriber everything related to queue dicovering
 - Job Queue is responsible of queue dicovering and exposes functions to scan user queues.
 - Batch creates an interval to consume queues
 - Now Batch.start() does:
  * Finds existing queues from metadata, adding to queue index the ones that are not indexed yet
  * Binds callback to process jobs for every queue found.
  * Inits queue consumer interval
  * Subscribes to PUB/SUB channel
2017-04-03 19:26:21 +02:00