Hi,
I see that you create a router with a set of workers:
// distributing the message processing across a pool of 5 actors
ActorRef workRouter =
akkaSystem.actorOf(new
RoundRobinPool(numOfWorkers).props(Props.create(EventProcessor.class)),
workRouter);
Hi,
I am trying out a competing event consumer implementation using Akka and
Camel. Am using Akka 2.3.2 and Camel 5.8.0. I am connecting camel to
ActiveMQ broker and using a producer to generate messages from other end.
In the following code EventManager is the master which creates pool of
