Thanks Andreas!
--
View this message in context:
http://camel.465427.n5.nabble.com/Can-not-consume-messages-which-are-sent-to-temp-queue-using-2-different-camel-contexts-tp5738891p5738969.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hi all,
I have 2 machines, one for producer and one for consumer. Sometime I need to
create some temp queues for sending/receiving messages. But I see that I can
not use temp queue this case. All messages are lot. I suspect the cause is
due to using 2 different camel contexts so I wrote below code
Thanks for your reply!
I find out the reason: I used a topic and set the maximumConcurrrentConsumer
= 10. This is really not recommended. I read some documents about the
concurrent consumer and see that we should only set the concurrentconsumer
if we are using a queue.
I also find out another dis
I'm using Camel 2.11.0:
org.apache.camel
camel-core
2.11.0
org.apache.camel
camel-jms
2.11.0
org.apache.camel
camel-spring
Can someone help me on this?
Seem there is a problem with the processor when it is used with the Topic.
Thanks,
Nhan
--
View this message in context:
http://camel.465427.n5.nabble.com/The-producer-sent-only-one-message-but-the-comsumer-received-multiple-messages-with-same-content-tp5736733p57
Thanks Christian for your test.
I had a look on your UT and re-checked my code. There is no problem with the
topic and the route config. The problem seem comes from Processor.
from("jms:topic:topic1").process(new Processor() {
@Override
public void process(Exchange exchange) th
Hi Christian,
I have plan I will use multiple comsumers.
Thanks,
Nhan
--
View this message in context:
http://camel.465427.n5.nabble.com/The-producer-sent-only-one-message-but-the-comsumer-received-multiple-messages-with-same-content-tp5736733p5736739.html
Sent from the Camel - Users mailing
Note: If I use the PollingConsumer, I don't see this problem.
--
View this message in context:
http://camel.465427.n5.nabble.com/The-producer-sent-only-one-message-but-the-comsumer-received-multiple-messages-with-same-content-tp5736733p5736734.html
Sent from the Camel - Users mailing list archi
Hi all,
I am using a Topic to send and receive the message:
from("jms:topic:topic1").process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
System.out.println(exchange.getIn().getBody()
