i'm trying stay connected multiple queues in rabbitmq. each time pop new message 1 of these queue, i'd spawn external process.
this process take time process message, , don't want start processing message specific queue until 1 popped earlier completed. if possible, wouldn't want keep process/thread around wait on external process complete , ack server. ideally, ack in external process, maybe passing identifier can connect rabbitmq , ack message.
is possible design system rabbitmq? i'm using python , pika, if relevant answer.
thanks!
rabbitmq can this.
you want read queue when you're ready - spin thread can spawn external process , watch it, fetch next message queue when process done. can have mulitiple threads running in parallel manage multiple queues.
i'm not sure want ack for? trying stop rabbitmq adding new elements queue if gets full (because elements being processed slowly/not @ all)? there might way when add messages queues - before adding item, check make sure number of messages in queue not "much greater than" average across queues?
Comments
Post a Comment