ServiceMix + Camel with Asynchronous Exchange

[Hamlet84 <do...@gmail.com>]

Hi. In a bean component of servicemix we create a message and then we send it
to a camel component.

in camel component
    public void configure() throws Exception {
        this.from("jbi:service:CamelTest")
        .process(new ProcessorFiltro());
    }
   
    private class ProcessorFiltro implements Processor{
        public void process(Exchange exchange) throws Exception {
            logger.info("ContentBasedRouter: processing...");
        }
    }

well, if into bean component we call

channel.sendSync(newExchange);

all works but if we call

channel.send(newExchange);

the camel component was invocated, but after we receive the error

ERROR - BeanComponent                  - Error processing exchange InOnly[
  id: ID:192.168.1.3-1157076a899-2:0
  status: Done
  role: consumer
  endpoint: camel192-168-1-3-1157076a899-11-33
  in: <?xml version="1.0" encoding="UTF-8"?....>
]

java.lang.IllegalStateException: Receiving unknown consumer exchange:
InOnly[
  id: ID:192.168.1.3-1157076a899-2:0
  status: Done
  role: consumer
...


it's seems that the channel or the message remains suspended

why??
-- 
View this message in context: http://www.nabble.com/ServiceMix-%2B-Camel-with-Asynchronous-Exchange-tf4777414s22882.html#a13666114
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: ServiceMix + Camel with Asynchronous Exchange

[Gert Vanthienen <ge...@skynet.be>]

L.S.,

This appears to be the same as 
https://issues.apache.org/activemq/browse/SM-944, which was resolved 
just before releasing ServiceMix 3.2.

If you aren't already doing so, could you retry this with an 'official' 
3.2 release of ServiceMix?  If the released version shows the same 
problem, you should probably raise a JIRA on this.  It would be nice if 
you could attach a failing SA for us to test with...

Gert



Hamlet84 wrote:
> Hi. In a bean component of servicemix we create a message and then we send it
> to a camel component.
>
> in camel component
>     public void configure() throws Exception {
>         this.from("jbi:service:CamelTest")
>         .process(new ProcessorFiltro());
>     }
>    
>     private class ProcessorFiltro implements Processor{
>         public void process(Exchange exchange) throws Exception {
>             logger.info("ContentBasedRouter: processing...");
>         }
>     }
>
> well, if into bean component we call
>
> channel.sendSync(newExchange);
>
> all works but if we call
>
> channel.send(newExchange);
>
> the camel component was invocated, but after we receive the error
>
> ERROR - BeanComponent                  - Error processing exchange InOnly[
>   id: ID:192.168.1.3-1157076a899-2:0
>   status: Done
>   role: consumer
>   endpoint: camel192-168-1-3-1157076a899-11-33
>   in: <?xml version="1.0" encoding="UTF-8"?....>
> ]
>
> java.lang.IllegalStateException: Receiving unknown consumer exchange:
> InOnly[
>   id: ID:192.168.1.3-1157076a899-2:0
>   status: Done
>   role: consumer
> ...
>
>
> it's seems that the channel or the message remains suspended
>
> why??
>