camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: Temporary consumers?
Date Mon, 12 Dec 2011 16:50:59 GMT
Hi

See this FAQ on AMQ which have some pointers. Maybe some of that is
possible for you.
In case you use a message broker or AMQ
http://activemq.apache.org/how-do-i-preserve-order-of-messages.html


On Mon, Dec 12, 2011 at 5:46 PM, Charles Hudak <meadandale@gmail.com> wrote:
> I'm wondering if something is possible...
>
> I have a need to implement FIFO queuing on a source basis but I have a
> potential to have thousands (millions?) of potential sources (e.g. a set of
> mobile devices). I want messages from each source to be processed in FIFO
> order seriallly but I need concurrency in general in the system (e.g.
> source A can be processed concurrently with source B but all of source A
> and source B's messages should be processed in serial fashion.
>
> Sources can theoretically join and leave the system at any time so there
> isn't any way to pre-configure them when the system starts.
>
> For capacity reasons idle source endpoints (consumers) should disposed of
> so they don't consume resources.
>
> So, in general, what I want to do is:
>
> When a message is received from sourceA an endpoint (consumer) is spun up
> to process the message (and any additional messages for sourceA that come
> in while the endpoint is active) but once the endpoint becomes idle and is
> receiving no more messages, it should be closed down.
>
> Is something like this doable in Camel? Does anyone know how I would
> configure things to get this to work?
>
> Thanks in advance for any pointers...
>
> Charles



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Mime
View raw message