Tagged Questions

3
votes
1answer
2k views

How to wait for messages on multiple queues using py-amqplib

I'm using py-amqplib to access RabbitMQ in Python. The application receives requests to listen on certain MQ topics from time to time. The first time it receives such a request it creates an AMQP ...
1
vote
1answer
49 views

Getting number of messages in a RabbitMQ queue

We're using amqplib to publish/consume messages. I want to be able to read the number of messages on a queue (ideally both acknowledged and unacknowledged). This will allow me to show a nice status ...
1
vote
1answer
805 views

Django ORM and multiprocessing

I am using Django ORM in my python script in a decoupled fashion i.e. it's not running in context of a normal Django Project. I am also using the multi processing module. And different process in ...
0
votes
1answer
117 views

How does reddit send email?

I am trying to learn how to large organisations that use python structure their code so that I can maybe apply some of their theories to my own code. Currently I am looking through reddit's code and ...
0
votes
1answer
96 views

Python stdout to queue broker or a websocket

Is there a way to push stdout into a queue broker or to a websocket? So far I've been unable to find a clear explanation on how to do this. I have several processes running in parallel and the idea ...
0
votes
1answer
197 views

Advice: Python Framework Server/Worker Queue management (not Website)

I am looking for some advice/opinions of which Python Framework to use in an implementation of multiple 'Worker' PCs co-ordinated from a central Queue Manager. For completeness, the 'Worker' PCs will ...
0
votes
0answers
28 views

Communication bridge between different users

I need to create some "queue system" (sorry, don't actually know how to call this). The idea is User A have one process up and running User B need to send a queue to the A's process, to instruct it ...
0
votes
0answers
92 views

Message queue: get messages since a certain time

I am implementing a specification for a web service. I have a function called getMessages(time) where you specify a time, and you get any messages since that time returned to you. I would like to back ...