ute is s1, s2, s3, s4, then:
> consumer.getProcessor().process(exchange) will return with the result of
> s2 while s3 and s4 run (in pipeline) asynchronously.
>
> Thank you for your help
>
> Ittay
>
-
Ben O'Day
IT Consultant -http://consulting-notes.com
--
View this message in co
Hi,
I have the need to create a route so that the processor that the
consumer holds runs 2 steps and then returns while the rest of the route
continues.
So, if the route is s1, s2, s3, s4, then:
consumer.getProcessor().process(exchange) will return with the result of
s2 while s3 and s4 run
r without waiting for a response. responses need to be processed
>>>>> asynchronously.So, I can't set sync flag to true, is there any other
>>>>> solution to my problem.
>>>>>
>>>>> Thanks,
>>>>> Anand
>>&
t;> other without waiting for a response. responses need to be processed
>>>>> asynchronously.So, I can't set sync flag to true, is there any other
>>>>> solution to my problem.
>>>>>
>>>>> Thanks,
&
https://issues.apache.org/activemq/browse/CAMEL-2540
--
View this message in context:
http://old.nabble.com/async-route-issue-with-Mina-endpoint-tp27865171p27865171.html
Sent from the Camel - Users mailing list archive at Nabble.com.
t;>>> public void process(Exchange exchange) throws Exception {
>>>>> String body = exchange.getIn().getBody(String.class);
>>>>> Thread.sleep(3);
>>>>>
String body = exchange.getIn().getBody(String.class);
>>>>Thread.sleep(3);
>>>>exchange.getOut().setBody("Bye 1" + body);
>>>>}
>>>> });
>>>>
>>
:6202?sync=true&textline=true",10)
>>> .to("log:+++ reply");
>>> To make sure the mina client can get the right response.
>>>
>>> Willem
>>>
>>> anandsk wrote:
>>>> Thanks. yes, I have seen the
client can get the right response.
>>
>> Willem
>>
>> anandsk wrote:
>>> Thanks. yes, I have seen the examples and I modified my code. but it
>>> still
>>> doesn't deliver reply asyncronously.
>>> I am thinking may be camel Mina'
gt; forwarding them to async endpoint. am I doing this wrong.
>>>>>>>
>>>>>>> Thanks,
>>>>>>> Anand
>>>>>>>
>>>>>>>
>>>>>>> from("mina:tcp://localhost:6202?textline=true&sync=true")
quot;);
To make sure the mina client can get the right response.
Willem
anandsk wrote:
Thanks. yes, I have seen the examples and I modified my code. but it
still
doesn't deliver reply asyncronously.
I am thinking may be camel Mina's sync option may be conflicting with
async
route.
nc("mina:tcp://localhost:6202?sync=true&textline=true",10)
>> .to("log:+++ reply");
>> To make sure the mina client can get the right response.
>>
>> Willem
>>
>> anandsk wrote:
>>> Thanks. yes, I have seen the examples
my code. but it
>> still
>> doesn't deliver reply asyncronously.
>> I am thinking may be camel Mina's sync option may be conflicting with
>> async
>> route. Please see my code below.
>>
>>
>> from("mina:tcp://localhost:6202?
't deliver reply asyncronously.
I am thinking may be camel Mina's sync option may be conflicting with async
route. Please see my code below.
from("mina:tcp://localhost:6202?textline=true&sync=true").process(new
Processor() {
public void
Thanks. yes, I have seen the examples and I modified my code. but it still
doesn't deliver reply asyncronously.
I am thinking may be camel Mina's sync option may be conflicting with async
route. Please see my code below.
from("mina:tcp://localhost:6202?textline
.setHeader(MinaEndpoint.HEADER_MINA_IOSESSION, expression)
> .to("mina:tcp://localhost:6202?textline=true&sync=true")
> .toAsync("direct:response",1)
> .to("log:direct");
>
> from("
from("direct:response")
.to("log:jms.queue.message");
--
View this message in context:
http://old.nabble.com/Mina-async-route-not-working-tp27757690p27757690.html
Sent from the Camel - Users mailing list archive at Nabble.com.
17 matches
Mail list logo
