DONE!!!

1. create a file called web2py-rq.py

#!/usr/bin/env python
import sys
from rq import Queue, Connection, Worker

# Preload libraries
#import library_that_you_want_preloaded

# Provide queue names to listen to as arguments to this script,
# similar to rqworker
with Connection():
    qs = map(Queue, sys.argv[1:]) or [Queue()]
    w = Worker(qs)
    w.work()

2. start the worker in web2py context
python web2py.py -S yourapp -M -R /path/to/web2py-rq.py


Now it is easiest to send delayed messages!

I will create a slice and will send the script to be included in contrib.

-- 



Reply via email to