|
a/mail/app/handlers/amqp.py |
|
b/mail/app/handlers/amqp.py |
|
... |
|
... |
| 18 |
userid="celeryuser", password="celerypw",
|
18 |
userid="celeryuser", password="celerypw",
|
| 19 |
virtual_host="celeryvhost")
|
19 |
virtual_host="celeryvhost")
|
| 20 |
|
20 |
|
| 21 |
publisher = Publisher(connection=conn,
|
21 |
publisher = Publisher(connection=conn,
|
| 22 |
exchange="forge", routing_key="mail")
|
22 |
exchange="forge", routing_key="mail")
|
| 23 |
publisher.send({"message": message})
|
23 |
publisher.send({"message": message}, serializer="pickle")
|
| 24 |
publisher.close()
|
24 |
publisher.close()
|
| 25 |
|
25 |
|
| 26 |
#index_q = queue.Queue("run/posts")
|
26 |
#index_q = queue.Queue("run/posts")
|
| 27 |
#index_q.push(message)
|
27 |
#index_q.push(message)
|
| 28 |
|
28 |
|