celery.node
celery.node copied to clipboard
How to send tasks with persistent mode?
Hi, I got into an issue is that sometimes my rabbitMQ server is dead or restarted and all messages that in queue is gone.
So I wonder, how can we send tasks with persistent mode instead of memory mode?
Hi. Sorry for late. Thank you for reporting the issue.
Unfortunately, there are no detailed task options.
https://github.com/actumn/celery.node/blob/1dfc0236452b6b72624ec57e0b729350f3874787/src/app/client.ts#L97-L100
For persistent mode, it requires adding delivery_mode on the task properties above.
It's not such a hard task, so if you want, I can add delivery_mode as default as soon as possible.
And feel free to make any Pull Requests. :)
Thank you.