You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Matt Narrell <ma...@gmail.com> on 2012/04/04 01:25:45 UTC
camel-netty psuedo proxy?
I have a route:
from("netty:tcp://somewhere:1234?...")
.to("bean:myBean?method=callOut")
Where the callOut method does several things, followed by a producerTemplate call to another netty endpoint:
producerTemplate.sendBody("netty:tcp://somewhereElse:6789...", ExchangePattern.InOut, body);
I'm unable to proxy "directly" from/to the netty endpoints, and need to pass through this bean. However, I receive the following exception:
Caused by: java.lang.IllegalStateException: await*() in I/O thread causes a dead lock or sudden performance drop. Use addListener() instead or call await*() from a different thread.
Is this route arrangement possible? All comm is synchronous request/reply.
-matt
Re: camel-netty psuedo proxy?
Posted by Matt Narrell <ma...@gmail.com>.
https://issues.apache.org/jira/browse/CAMEL-5151
Thanks,
mn
On Apr 9, 2012, at 5:51 AM, Willem Jiang wrote:
> Can you fill a JIRA[1] for it ?
>
> [1] https://issues.apache.org/jira/browse/CAMEL
>
> On Fri Apr 6 10:27:25 2012, Matt Narrell wrote:
>> This works fine with Mina, but chokes with Netty...
>>
>> On Apr 3, 2012, at 4:25 PM, Matt Narrell<ma...@gmail.com> wrote:
>>
>>> I have a route:
>>>
>>> from("netty:tcp://somewhere:1234?...")
>>> .to("bean:myBean?method=callOut")
>>>
>>> Where the callOut method does several things, followed by a producerTemplate call to another netty endpoint:
>>>
>>> producerTemplate.sendBody("netty:tcp://somewhereElse:6789...", ExchangePattern.InOut, body);
>>>
>>> I'm unable to proxy "directly" from/to the netty endpoints, and need to pass through this bean. However, I receive the following exception:
>>>
>>> Caused by: java.lang.IllegalStateException: await*() in I/O thread causes a dead lock or sudden performance drop. Use addListener() instead or call await*() from a different thread.
>>>
>>> Is this route arrangement possible? All comm is synchronous request/reply.
>>>
>>> -matt
>>
>
>
>
> --
> Willem
> ----------------------------------
> CamelOne 2012 Conference, May 15-16, 2012: http://camelone.com
> FuseSource
> Web: http://www.fusesource.com
> Blog: http://willemjiang.blogspot.com (English)
> http://jnn.javaeye.com (Chinese)
> Twitter: willemjiang
> Weibo: willemjiang
>
Re: camel-netty psuedo proxy?
Posted by Willem Jiang <wi...@gmail.com>.
Can you fill a JIRA[1] for it ?
[1] https://issues.apache.org/jira/browse/CAMEL
On Fri Apr 6 10:27:25 2012, Matt Narrell wrote:
> This works fine with Mina, but chokes with Netty...
>
> On Apr 3, 2012, at 4:25 PM, Matt Narrell<ma...@gmail.com> wrote:
>
>> I have a route:
>>
>> from("netty:tcp://somewhere:1234?...")
>> .to("bean:myBean?method=callOut")
>>
>> Where the callOut method does several things, followed by a producerTemplate call to another netty endpoint:
>>
>> producerTemplate.sendBody("netty:tcp://somewhereElse:6789...", ExchangePattern.InOut, body);
>>
>> I'm unable to proxy "directly" from/to the netty endpoints, and need to pass through this bean. However, I receive the following exception:
>>
>> Caused by: java.lang.IllegalStateException: await*() in I/O thread causes a dead lock or sudden performance drop. Use addListener() instead or call await*() from a different thread.
>>
>> Is this route arrangement possible? All comm is synchronous request/reply.
>>
>> -matt
>
--
Willem
----------------------------------
CamelOne 2012 Conference, May 15-16, 2012: http://camelone.com
FuseSource
Web: http://www.fusesource.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang
Re: camel-netty psuedo proxy?
Posted by Matt Narrell <ma...@gmail.com>.
This works fine with Mina, but chokes with Netty...
On Apr 3, 2012, at 4:25 PM, Matt Narrell <ma...@gmail.com> wrote:
> I have a route:
>
> from("netty:tcp://somewhere:1234?...")
> .to("bean:myBean?method=callOut")
>
> Where the callOut method does several things, followed by a producerTemplate call to another netty endpoint:
>
> producerTemplate.sendBody("netty:tcp://somewhereElse:6789...", ExchangePattern.InOut, body);
>
> I'm unable to proxy "directly" from/to the netty endpoints, and need to pass through this bean. However, I receive the following exception:
>
> Caused by: java.lang.IllegalStateException: await*() in I/O thread causes a dead lock or sudden performance drop. Use addListener() instead or call await*() from a different thread.
>
> Is this route arrangement possible? All comm is synchronous request/reply.
>
> -matt