I a开发者_如何学编程m looking to implement a priority queue with RabbitMQ. The mailing list recommends to use multiple queues, each queue representing a different priority level.
The producer module of my application is run by users who want to submit work to be done on a small cluster. It sends the subscriptions in JSON form through the RabbitMQ message broker.
I\'m trying to set up a worker daemon for processing messages from rabbitmq.I\'m using pik开发者_运维问答a and its SelectConnection.The code works fine if I don\'t run it as a daemon.I can use
I\'d like to do some routing magic with AMQP. My setup is Python with Pika on the consumer/producer side and RabbitMQ for the AMQP server.
If i have a header file foo.h and a source file foo.cpp, and foo.cpp contains something along the lines of: