Re: ServiceMix Bean Problems with (Robust) In Only

[Andreas Schaefer]

Hi Guillaume








Andreas Schaefer
CEO of Madplanet.com Inc.
[EMAIL PROTECTED]


On Oct 9, 2007, at 10:34 PM, Guillaume Nodet wrote:

I found two things that may contribute to this problem in the BeanEndpoint class: 1) When a message is set to DONE and is sent back then the role switches from Provider to Consumer. I don't know if that is correct but it then leads to the problem. 2) The onConsumerExchange() method it only checks if the Request is available in the "requests" Map. But when the message is sent asynchronously then the DONE message is handled by another BeanEndpoint instance making it impossible to find the request in the Map. I don't know whey the onConsumerExchange() method must match the request but either the requests Map must be static or this must only be enforced for synchronous calls.

I suppose this is related to this bug. Have you tried the workaround ?

I'm not quite sure how to solve the problem yet...

On 10/10/07, Andreas Schaefer <[EMAIL PROTECTED]> wrote:

Hi Geeks


https://issues.apache.org/activemq/browse/SM-944 but it is

the cause.

This exceptions were created with 3.1.2:

2007-10-09 20:54:38,849 [1b-0:0-thread-3] ERROR BeanComponent
  - Error processing exchange RobustInOnly[
  id: ID:192.168.0.11-115880c5d1b-2:0
  status: Done
  role: consumer
  service: {urn:scout}receiver-service
  endpoint: receiver
  operation: IdontCare: 0
  in: <?xml version="1.0"

]
java.lang.IllegalStateException: Receiving unknown consumer exchange:
RobustInOnly[
  id: ID:192.168.0.11-115880c5d1b-2:0
  status: Done
  role: consumer
  service: {urn:scout}receiver-service
  endpoint: receiver
  operation: IdontCare: 0
  in: <?xml version="1.0"

]
        at

        at

        at

        at

        at

        at

        at

        at

        at

        at

        at

        at java.lang.Thread.run(Thread.java:613)

Thanks


Andreas Schaefer
CEO of Madplanet.com Inc.
[EMAIL PROTECTED]

I was trying to use Robust In Only with ServiceMix-Bean but I always get an exception when I send the message back as Done. It found this JIRA issue: not implemented in 3.1.2 and so I was wondering what is going on and what is encoding="UTF-8"?><receiver><title>DontCareEvenMore</ title><index>0</index></receiver> encoding="UTF-8"?><receiver><title>DontCareEvenMore</ title><index>0</index></receiver> org.apache.servicemix.bean.BeanEndpoint.onConsumerExchange (BeanEndpoint.java:266) org.apache.servicemix.bean.BeanEndpoint.process(BeanEndpoint.java: 196) org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess (AsyncBaseLifeCycle.java:489) org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange (AsyncBaseLifeCycle.java:463) org.apache.servicemix.common.BaseLifeCycle.onMessageExchange (BaseLifeCycle.java:46) org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun d(DeliveryChannelImpl.java:595) org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting (AbstractFlow.java:174) org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting (SedaFlow.java:176) org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run (SedaQueue.java:134) edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor $Worker.runTask(ThreadPoolExecutor.java:665) edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor $Worker.run(ThreadPoolExecutor.java:690)

--
Cheers,
Guillaume Nodet
------------------------
Blog: http://gnodet.blogspot.com/

PGP.sig
Description: This is a digitally signed message part