Daniel García Aubert
|
0586f45413
|
Added callback to job subscriber to allow to batch service emit ready event
|
2016-07-22 13:47:14 +02:00 |
|
Daniel García Aubert
|
5eaad4d5d9
|
Uses redis-mpool for pubsub in Batch API
|
2016-07-07 14:14:46 +02:00 |
|
Daniel García Aubert
|
74d83a457e
|
Now batch publisher sends a ping to server before publishing and create a new connection if error.
Batch publisher and subscriber logs (if debug enabled) both outcoming and incoming messages to give more visibility.
|
2016-07-07 10:44:17 +02:00 |
|
Daniel García Aubert
|
8b7d481b9a
|
Avoided console usage, favor debug
|
2016-05-18 11:06:49 +02:00 |
|
Daniel García Aubert
|
1414e0a9dd
|
Fix #276, reload subcription to PUBSUB channel and looks for queues every 10 minutes
|
2016-04-04 20:00:18 +02:00 |
|
Daniel García Aubert
|
b62edcb64f
|
Refactored batch-api startup. Isolated code related to queue discovering, api much clear and concise.
|
2016-04-04 16:05:33 +02:00 |
|
dgaubert
|
ed070e3040
|
Used SCAN instead of KEYS for looking for queues when Batch API starts
|
2016-04-01 15:03:32 +02:00 |
|
dgaubert
|
e8a44136c5
|
Now Batch API looks for queues with jobs to consume at service initialization time
|
2016-03-31 17:37:35 +02:00 |
|
Daniel García Aubert
|
e6f714a51b
|
Implemented some new unit test
|
2016-01-22 19:31:25 +01:00 |
|
Daniel García Aubert
|
8c42019641
|
Improved namespace in redis for batch's stuff
|
2015-12-29 15:46:04 +01:00 |
|
Daniel García Aubert
|
3c23bf12e7
|
Fixed bug whether a job consumer is empty. And refactored batch module, now is a common object intead of module function
|
2015-12-22 20:12:10 +01:00 |
|
Daniel García Aubert
|
43f759e96a
|
Refactored Batch API using streams instead a interval to consume the job queue. Limited one job running at the same time per queue instead of using a job's counter to limit it.
|
2015-12-16 15:57:58 +01:00 |
|