[rabbitmq-discuss] Am I using Queues Correctly?
alexandru at rabbitmq.com
Mon Sep 6 14:38:17 BST 2010
There's nothing inherently wrong with what you describe.
Depending on what you filter on, you could make it simpler. If you
filter on a message name/id or something like that, you could probably
just bind the filtered queue to a direct exchange (match on the routing
key) or a topic exchange (match on something like a regexp).
If you're filtering rules are more complicated or if they involve
inspecting the message content, what you're doing is probably the way
to go. You could also write a custom exchange type as a plugin.
On Mon, Sep 06, 2010 at 02:03:44PM +0100, Tom Martin wrote:
> I'm building a system which takes incoming messages, filters them and stores
> them to DB. I have each of these three bits running as separate ruby
> processes, if the filter or database saving processes die then when they
> come back, new messages are waiting in the queue.
> I've implemented this using two separate queues: an incoming queue and
> a filtered queue. The filtering process just takes the incoming queue, does
> it's business and inserts it into the filtered queue. The DB storing process
> takes the filtered queue and stores them to DB.
> I'm very new to RabbitMQ, is this kind of flow correct, creating two
> different queues? or is there a better way to do it using Exchanges or some
> other part of RabbitMQ?
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
More information about the rabbitmq-discuss