actumn
How to implement ETA, crontab?
like node-celery : var celery = require('node-celery'), client = celery.createClient({ CELERY_BROKER_URL: 'amqp://guest:guest@localhost:5672//', });
client.on('connect', function() { client.call('send-email', { to: '[email protected]', title: 'sample email' }, { eta: new Date(Date.now() + 60 * 60 * 1000) // an hour later }); });
Hi.
Unfortunately, ETA is not implemented yet on celery.node.
Client-side task options like eta are quite easy to implement. (just add to task message)
But on the other hand, we have to consider how to dispatch messages at the time or recover messages when the worker is terminating on worker-side implementation.
So I'm thinking about it nowadays.
If you want to eta feature on just the client-side, I can make it as soon as possible.
