Can anyone help me with this, please?
On Fri, 7 Feb 2020 at 13:31, sujin sr wrote:
> I have a route which read messages from an ActiveMQ queue and writes to
> another queue.
> When message load increases consumers count reaching
> maxConcurrentConsumers value but when message lo
I have a route which read messages from an ActiveMQ queue and writes to
another queue.
When message load increases consumers count reaching maxConcurrentConsumers
value but when message load decreases or producer stopped then consumer
count not coming down to idleConsumerLimit value.
I am using
Hi,
> you have probably meant to use
> {{sample.route.myroute.processor.myprocessorid}}
>
> Dne 23.9.2019 v 14:30 sujin sr napsal(a):
> > Hi,
> >
> > I have a .yml file where all the route information has been defined, i
> have
> > injected the value into the
Hi,
I have a .yml file where all the route information has been defined, i have
injected the value into the route. But injected value has been applied for
route id and autostartup but value not has been applied for custom
processor id. I am using springboot to start the camel context
example
Hi Claus Ibsen ,
Could you please provide some input on the previous queries?
Thanks.
On Wed, 7 Aug 2019 at 13:07, sujin sr wrote:
> Thanks Claus Ibsen for the response.
>
> So If I process replyQueue via a separate route I am wondering about the
> below two points
> 1. How
ly queues with InOut and with
> transactions as its a chicken/egg situation.
> The message that is sent to the request queue (for req/reply) is not
> committed until the transaction is committed and therefore the
> received cannot "see" the message.
>
> On Wed, Aug 7, 2019 a
Hi,
I have a use case where two jms queues are available those are
DataRequestQueue and DataReplyQueue. Where If I sent a message to the
DataRequestQueue MDB will process the message and send the response to
DataReplyQueue.
I have used Camel to send the message and receive the response. I have
fore endChoice in 2 split?
Correct me if my understanding is wrong.
On Fri, 26 Jul 2019 at 14:23, Claus Ibsen wrote:
> You have 2 splits, so you need and end before the end choice
>
> On Fri, Jul 26, 2019 at 10:51 AM sujin sr wrote:
> >
> > I am getting ClassCastException
I am getting ClassCastException while trying to execute camel route
from("timer://messageSplitterTest?repeatCount=1")
.process(exchange -> {
Message message = exchange.getMessage();
List ongoingMessages = new ArrayList<>();
for (int i = 0; i < 10; i++)
ple you need to setup a 2nd JMS component for ERROR, so
> > > the JMS can rollback, and ERROR can commit. Also mind that the
> > > incoming endpoint is also JMS and it will also rollback as part of ONE
> > > and TWO. So you will get the message redelibered again from the
&
u will get the message redelibered again from the
> broker.
>
> So try instead to just use broker error handling.
>
>
>
>
> On Wed, Jun 26, 2019 at 9:01 AM sujin sr wrote:
> >
> > I am facing a issue while trying to implement JMS transaction using
> Camel.
> &g
I am facing a issue while trying to implement JMS transaction using Camel.
Here is the scenario
1. Primary route which read the message from the queue(JMS_IN), pass the
same exchange to the two sub route(direct route)
2. First sub route process the message successfully and send to the another
12 matches
Mail list logo
