camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Edwin <>
Subject Camel Component - Consumer Threading Question
Date Fri, 08 Jun 2012 18:48:14 GMT
Hi Folks, 

I am currently developing a Camel component comprising of both consumer and
producer endpoints. The consumer will ping a Socket connection. When a
connection has been established, a session is then created

In the system there will be 100+ sessions. I plan to build the Camel route
dynamically so there will be a route consuming from each session

So for N sessions, there will be N routes and each session and route runs on
it's own thread

Applying threading on the route does not present any issues however this is
proving more challenging on the consumer. 

I have been looking at the ScheduledPollConsumer and I could extend this
class and override it's run() and make one or two other changes so it fits
my use case but it's not the cleanest of solutions

I'm wondering if Camel provides anything out of the box that ensures a
consumer is created in it's own thread? 

Any thoughts on this topic are much appreciated,


In the component, I would like the consumer to consume from each of these
individual threads however the consumer should have it's own thread to read
from an individual session thread. So the mapping between session and
consumer is: N sessions : N consumers. create a route that For the consumer,
i'm wondering is it possible to create a thread for every consumer. The
application of this component 

View this message in context:
Sent from the Camel - Users mailing list archive at

View raw message