[mule-user] Routing Exception

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

[mule-user] Routing Exception

Valada, Narendra

Hi All,

 

I am using Mule 1.0 and I am getting the following exception:

 

********************************************************************************

Message          : Failed to route event via endpoint: null. Message payload is of type: org.apache.commons.dbutils.BasicRowProcessor$CaseInsensitiveHashMap

Type             : org.mule.umo.routing.RoutingException

Code             : 39999

JavaDoc          : http://mule.codehaus.org/docs/apidocs/org/mule/umo/routing/RoutingException.html

Payload          : {=X}

********************************************************************************

Exception stack is:

1. Adpater "org.mule.providers.jdbc.JdbcMessageAdapter" does not support unique identifiers (org.mule.umo.provider.UniqueIdNotSupportedException)

  org.mule.providers.AbstractMessageAdapter:80 (http://mule.codehaus.org/docs/apidocs/org/mule/umo/provider/UniqueIdNotSupportedException.html)

2. Failed to route event via endpoint: null. Message payload is of type: org.apache.commons.dbutils.BasicRowProcessor$CaseInsensitiveHashMap (org.mule.umo.routing.RoutingException)

  org.mule.routing.outbound.OutboundMessageRouter:89 (http://mule.codehaus.org/docs/apidocs/org/mule/umo/routing/RoutingException.html)

********************************************************************************

Root Exception stack trace:

org.mule.umo.provider.UniqueIdNotSupportedException: Adpater "org.mule.providers.jdbc.JdbcMessageAdapter" does not support unique identifiers

      at org.mule.providers.AbstractMessageAdapter.getUniqueId(AbstractMessageAdapter.java:80)

      at org.mule.impl.MuleMessage.getUniqueId(MuleMessage.java:186)

      at org.mule.routing.DefaultPropertiesExtractor.getMessageId(DefaultPropertiesExtractor.java:54)

      at org.mule.routing.DefaultPropertiesExtractor.getCorrelationId(DefaultPropertiesExtractor.java:58)

      at org.mule.routing.DefaultPropertiesExtractor.getPropertry(DefaultPropertiesExtractor.java:37)

      at org.mule.routing.outbound.AbstractOutboundRouter.setMessageProperties(AbstractOutboundRouter.java:118)

      at org.mule.routing.outbound.AbstractOutboundRouter.send(AbstractOutboundRouter.java:80)

      at org.mule.routing.outbound.FilteringOutboundRouter.route(FilteringOutboundRouter.java:55)

      at org.mule.routing.outbound.OutboundPassThroughRouter.route(OutboundPassThroughRouter.java:75)

      at org.mule.routing.outbound.OutboundMessageRouter$1.doInTransaction(OutboundMessageRouter.java:81)

      at org.mule.transaction.TransactionTemplate.execute(TransactionTemplate.java:45)

      at org.mule.routing.outbound.OutboundMessageRouter.route(OutboundMessageRouter.java:86)

      at org.mule.routing.inbound.ForwardingConsumer.process(ForwardingConsumer.java:51)

      at org.mule.routing.inbound.InboundMessageRouter.route(InboundMessageRouter.java:80)

      at org.mule.providers.AbstractMessageReceiver.routeMessage(AbstractMessageReceiver.java:225)

      at org.mule.providers.AbstractMessageReceiver.routeMessage(AbstractMessageReceiver.java:160)

      at com.ustrust.service.account.esb.mule.providers.WASJdbcMessageReceiver.processMessage(WASJdbcMessageReceiver.java:85)

      at org.mule.providers.TransactedPollingMessageReceiver$2.doInTransaction(TransactedPollingMessageReceiver.java:75)

      at org.mule.transaction.TransactionTemplate.execute(TransactionTemplate.java:66)

      at org.mule.providers.TransactedPollingMessageReceiver.poll(TransactedPollingMessageReceiver.java:79)

      at org.mule.providers.PollingMessageReceiver.run(PollingMessageReceiver.java:69)

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

 

 

 

Excerpts from my mule-config file follow:

 

 

    <transformers>

        <transformer name="ObjectToJMSMessage" className="org.mule.providers.jms.transformers.ObjectToJMSMessage"

            returnClass="javax.jms.MapMessage"/>                 

    </transformers>

    <global-endpoints>

      <endpoint name="jdbcOnAccountChange" address="jdbc://onAccountChange?createConnector=ALWAYS" type="receiver"/>    

      <endpoint name="jmsOnAccountChange" address="jms://AccountService.onAccountChangeQueue?connector=jmsConnector" type="senderAndReceiver">    

      </endpoint>

      <endpoint name="jmsOnFeesChange" address="jms://AccountService.onFeesChangeQueue?connector=jmsConnector" type="senderAndReceiver">    

      </endpoint>

    </global-endpoints>

  

           

    <model name="AccountService">

      <mule-descriptor name="OnAccountChangeExec1"

                        inboundEndpoint="jdbcOnAccountChange"

                        outboundEndpoint="jmsOnAccountChange"

                        outboundTransformer="ObjectToJMSMessage"

                        implementation="org.mule.components.simple.NullComponent"> 

          <inbound-router>

          <router className="org.mule.routing.inbound.ForwardingConsumer"/>

          </inbound-router>                                      

      </mule-descriptor>

    </model>

 

 

Thanks in advance

 

Narendra

 

--------------------------------------------------------------------- The message contains confidential and/or legally privileged information and is intended for use by the indicated addressee. If you are not the intended addressee: (a) any disclosure, reproduction, distribution or action you take because of it is strictly prohibited; (b) please return the complete message to the sender; and (c) this message is not a solicitation for purchase or sale or an agreement of any kind whatsoever that binds the sender. ---------------------------------------------------------------------
Reply | Threaded
Open this post in threaded view
|

RE: [mule-user] Routing Exception

Valada, Narendra

Hi all,

 

Just to outline what I am trying to accomplish here: I need to have a JdbcMessageReceiver poll a table and send the resultset back a row at a time to a JMS queue. I am using a ObjectToJMSMessage transformer to create a javax.jms.mapmessage that is then sent to the queue.

 

What is the best way to accomplish this? Thanks in advance.

 

Narendra

 

-----Original Message-----
From: Valada, Narendra
Sent: Thursday, July 14, 2005 10:07 AM
To: [hidden email]
Subject: [mule-user] Routing Exception

 

Hi All,

 

I am using Mule 1.0 and I am getting the following exception:

 

********************************************************************************

Message          : Failed to route event via endpoint: null. Message payload is of type: org.apache.commons.dbutils.BasicRowProcessor$CaseInsensitiveHashMap

Type             : org.mule.umo.routing.RoutingException

Code             : 39999

JavaDoc          : http://mule.codehaus.org/docs/apidocs/org/mule/umo/routing/RoutingException.html

Payload          : {=X}

********************************************************************************

Exception stack is:

1. Adpater "org.mule.providers.jdbc.JdbcMessageAdapter" does not support unique identifiers (org.mule.umo.provider.UniqueIdNotSupportedException)

  org.mule.providers.AbstractMessageAdapter:80 (http://mule.codehaus.org/docs/apidocs/org/mule/umo/provider/UniqueIdNotSupportedException.html)

2. Failed to route event via endpoint: null. Message payload is of type: org.apache.commons.dbutils.BasicRowProcessor$CaseInsensitiveHashMap (org.mule.umo.routing.RoutingException)

  org.mule.routing.outbound.OutboundMessageRouter:89 (http://mule.codehaus.org/docs/apidocs/org/mule/umo/routing/RoutingException.html)

********************************************************************************

Root Exception stack trace:

org.mule.umo.provider.UniqueIdNotSupportedException: Adpater "org.mule.providers.jdbc.JdbcMessageAdapter" does not support unique identifiers

      at org.mule.providers.AbstractMessageAdapter.getUniqueId(AbstractMessageAdapter.java:80)

      at org.mule.impl.MuleMessage.getUniqueId(MuleMessage.java:186)

      at org.mule.routing.DefaultPropertiesExtractor.getMessageId(DefaultPropertiesExtractor.java:54)

      at org.mule.routing.DefaultPropertiesExtractor.getCorrelationId(DefaultPropertiesExtractor.java:58)

      at org.mule.routing.DefaultPropertiesExtractor.getPropertry(DefaultPropertiesExtractor.java:37)

      at org.mule.routing.outbound.AbstractOutboundRouter.setMessageProperties(AbstractOutboundRouter.java:118)

      at org.mule.routing.outbound.AbstractOutboundRouter.send(AbstractOutboundRouter.java:80)

      at org.mule.routing.outbound.FilteringOutboundRouter.route(FilteringOutboundRouter.java:55)

      at org.mule.routing.outbound.OutboundPassThroughRouter.route(OutboundPassThroughRouter.java:75)

      at org.mule.routing.outbound.OutboundMessageRouter$1.doInTransaction(OutboundMessageRouter.java:81)

      at org.mule.transaction.TransactionTemplate.execute(TransactionTemplate.java:45)

      at org.mule.routing.outbound.OutboundMessageRouter.route(OutboundMessageRouter.java:86)

      at org.mule.routing.inbound.ForwardingConsumer.process(ForwardingConsumer.java:51)

      at org.mule.routing.inbound.InboundMessageRouter.route(InboundMessageRouter.java:80)

      at org.mule.providers.AbstractMessageReceiver.routeMessage(AbstractMessageReceiver.java:225)

      at org.mule.providers.AbstractMessageReceiver.routeMessage(AbstractMessageReceiver.java:160)

      at com.ustrust.service.account.esb.mule.providers.WASJdbcMessageReceiver.processMessage(WASJdbcMessageReceiver.java:85)

      at org.mule.providers.TransactedPollingMessageReceiver$2.doInTransaction(TransactedPollingMessageReceiver.java:75)

      at org.mule.transaction.TransactionTemplate.execute(TransactionTemplate.java:66)

      at org.mule.providers.TransactedPollingMessageReceiver.poll(TransactedPollingMessageReceiver.java:79)

      at org.mule.providers.PollingMessageReceiver.run(PollingMessageReceiver.java:69)

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

 

 

 

Excerpts from my mule-config file follow:

 

 

    <transformers>

        <transformer name="ObjectToJMSMessage" className="org.mule.providers.jms.transformers.ObjectToJMSMessage"

            returnClass="javax.jms.MapMessage"/>                 

    </transformers>

    <global-endpoints>

      <endpoint name="jdbcOnAccountChange" address="jdbc://onAccountChange?createConnector=ALWAYS" type="receiver"/>    

      <endpoint name="jmsOnAccountChange" address="jms://AccountService.onAccountChangeQueue?connector=jmsConnector" type="senderAndReceiver">    

      </endpoint>

      <endpoint name="jmsOnFeesChange" address="jms://AccountService.onFeesChangeQueue?connector=jmsConnector" type="senderAndReceiver">    

      </endpoint>

    </global-endpoints>

  

           

    <model name="AccountService">

      <mule-descriptor name="OnAccountChangeExec1"

                        inboundEndpoint="jdbcOnAccountChange"

                        outboundEndpoint="jmsOnAccountChange"

                        outboundTransformer="ObjectToJMSMessage"

                        implementation="org.mule.components.simple.NullComponent"> 

          <inbound-router>

          <router className="org.mule.routing.inbound.ForwardingConsumer"/>

          </inbound-router>                                      

      </mule-descriptor>

    </model>

 

 

Thanks in advance

 

Narendra

 

--------------------------------------------------------------------- The message contains confidential and/or legally privileged information and is intended for use by the indicated addressee. If you are not the intended addressee: (a) any disclosure, reproduction, distribution or action you take because of it is strictly prohibited; (b) please return the complete message to the sender; and (c) this message is not a solicitation for purchase or sale or an agreement of any kind whatsoever that binds the sender. ---------------------------------------------------------------------
--------------------------------------------------------------------- The message contains confidential and/or legally privileged information and is intended for use by the indicated addressee. If you are not the intended addressee: (a) any disclosure, reproduction, distribution or action you take because of it is strictly prohibited; (b) please return the complete message to the sender; and (c) this message is not a solicitation for purchase or sale or an agreement of any kind whatsoever that binds the sender. ---------------------------------------------------------------------
Reply | Threaded
Open this post in threaded view
|

Re: [mule-user] Routing Exception

Guillaume Nodet
I think this has been fixed in mule 1.1-rc1.
Would you please try with it ?

Cheers,
Guillaume Nodet

Valada, Narendra a ?crit :

> Hi all,
>
>  
>
> Just to outline what I am trying to accomplish here: I need to have a
> JdbcMessageReceiver poll a table and send the resultset back a row at
> a time to a JMS queue. I am using a ObjectToJMSMessage transformer to
> create a javax.jms.mapmessage that is then sent to the queue.
>
>  
>
> What is the best way to accomplish this? Thanks in advance.
>
>  
>
> Narendra
>
>  
>
> -----Original Message-----
> *From:* Valada, Narendra
> *Sent:* Thursday, July 14, 2005 10:07 AM
> *To:* [hidden email]
> *Subject:* [mule-user] Routing Exception
>
>  
>
> Hi All,
>
>  
>
> I am using Mule 1.0 and I am getting the following exception:
>
>  
>
> ********************************************************************************
>
> Message          : Failed to route event via endpoint: null. Message
> payload is of type:
> org.apache.commons.dbutils.BasicRowProcessor$CaseInsensitiveHashMap
>
> Type             : org.mule.umo.routing.RoutingException
>
> Code             : 39999
>
> JavaDoc          :
> http://mule.codehaus.org/docs/apidocs/org/mule/umo/routing/RoutingException.html
>
> Payload          : {=X}
>
> ********************************************************************************
>
> Exception stack is:
>
> 1. Adpater "org.mule.providers.jdbc.JdbcMessageAdapter" does not
> support unique identifiers
> (org.mule.umo.provider.UniqueIdNotSupportedException)
>
>   org.mule.providers.AbstractMessageAdapter:80
> (http://mule.codehaus.org/docs/apidocs/org/mule/umo/provider/UniqueIdNotSupportedException.html)
>
> 2. Failed to route event via endpoint: null. Message payload is of
> type:
> org.apache.commons.dbutils.BasicRowProcessor$CaseInsensitiveHashMap
> (org.mule.umo.routing.RoutingException)
>
>   org.mule.routing.outbound.OutboundMessageRouter:89
> (http://mule.codehaus.org/docs/apidocs/org/mule/umo/routing/RoutingException.html)
>
> ********************************************************************************
>
> Root Exception stack trace:
>
> org.mule.umo.provider.UniqueIdNotSupportedException: Adpater
> "org.mule.providers.jdbc.JdbcMessageAdapter" does not support unique
> identifiers
>
>       at
> org.mule.providers.AbstractMessageAdapter.getUniqueId(AbstractMessageAdapter.java:80)
>
>       at org.mule.impl.MuleMessage.getUniqueId(MuleMessage.java:186)
>
>       at
> org.mule.routing.DefaultPropertiesExtractor.getMessageId(DefaultPropertiesExtractor.java:54)
>
>       at
> org.mule.routing.DefaultPropertiesExtractor.getCorrelationId(DefaultPropertiesExtractor.java:58)
>
>       at
> org.mule.routing.DefaultPropertiesExtractor.getPropertry(DefaultPropertiesExtractor.java:37)
>
>       at
> org.mule.routing.outbound.AbstractOutboundRouter.setMessageProperties(AbstractOutboundRouter.java:118)
>
>       at
> org.mule.routing.outbound.AbstractOutboundRouter.send(AbstractOutboundRouter.java:80)
>
>       at
> org.mule.routing.outbound.FilteringOutboundRouter.route(FilteringOutboundRouter.java:55)
>
>       at
> org.mule.routing.outbound.OutboundPassThroughRouter.route(OutboundPassThroughRouter.java:75)
>
>       at
> org.mule.routing.outbound.OutboundMessageRouter$1.doInTransaction(OutboundMessageRouter.java:81)
>
>       at
> org.mule.transaction.TransactionTemplate.execute(TransactionTemplate.java:45)
>
>       at
> org.mule.routing.outbound.OutboundMessageRouter.route(OutboundMessageRouter.java:86)
>
>       at
> org.mule.routing.inbound.ForwardingConsumer.process(ForwardingConsumer.java:51)
>
>       at
> org.mule.routing.inbound.InboundMessageRouter.route(InboundMessageRouter.java:80)
>
>       at
> org.mule.providers.AbstractMessageReceiver.routeMessage(AbstractMessageReceiver.java:225)
>
>       at
> org.mule.providers.AbstractMessageReceiver.routeMessage(AbstractMessageReceiver.java:160)
>
>       at
> com.ustrust.service.account.esb.mule.providers.WASJdbcMessageReceiver.processMessage(WASJdbcMessageReceiver.java:85)
>
>       at
> org.mule.providers.TransactedPollingMessageReceiver$2.doInTransaction(TransactedPollingMessageReceiver.java:75)
>
>       at
> org.mule.transaction.TransactionTemplate.execute(TransactionTemplate.java:66)
>
>       at
> org.mule.providers.TransactedPollingMessageReceiver.poll(TransactedPollingMessageReceiver.java:79)
>
>       at
> org.mule.providers.PollingMessageReceiver.run(PollingMessageReceiver.java:69)
>
>       at java.lang.Thread.run(Thread.java:568)
>
>  
>
>  
>
>  
>
> Excerpts from my mule-config file follow:
>
>  
>
>  
>
>     <transformers>
>
>         <transformer name="ObjectToJMSMessage"
> className="org.mule.providers.jms.transformers.ObjectToJMSMessage"
>
>             returnClass="javax.jms.MapMessage"/>                
>
>     </transformers>
>
>     <global-endpoints>
>
>       <endpoint name="jdbcOnAccountChange"
> address="jdbc://onAccountChange?createConnector=ALWAYS"
> type="receiver"/>    
>
>       <endpoint name="jmsOnAccountChange"
> address="jms://AccountService.onAccountChangeQueue?connector=jmsConnector"
> type="senderAndReceiver">    
>
>       </endpoint>
>
>       <endpoint name="jmsOnFeesChange"
> address="jms://AccountService.onFeesChangeQueue?connector=jmsConnector"
> type="senderAndReceiver">    
>
>       </endpoint>
>
>     </global-endpoints>
>
>  
>
>            
>
>     <model name="AccountService">
>
>       <mule-descriptor name="OnAccountChangeExec1"
>
>                         inboundEndpoint="jdbcOnAccountChange"
>
>                         outboundEndpoint="jmsOnAccountChange"
>
>                         outboundTransformer="ObjectToJMSMessage"
>
>                        
> implementation="org.mule.components.simple.NullComponent">
>
>           <inbound-router>
>
>           <router
> className="org.mule.routing.inbound.ForwardingConsumer"/>
>
>           </inbound-router>                                      
>
>       </mule-descriptor>
>
>     </model>
>
>  
>
>  
>
> Thanks in advance
>
>  
>
> Narendra
>
>  
>
> ---------------------------------------------------------------------
> The message contains confidential and/or legally privileged
> information and is intended for use by the indicated addressee. If you
> are not the intended addressee: (a) any disclosure, reproduction,
> distribution or action you take because of it is strictly prohibited;
> (b) please return the complete message to the sender; and (c) this
> message is not a solicitation for purchase or sale or an agreement of
> any kind whatsoever that binds the sender.
> ---------------------------------------------------------------------
>
> ---------------------------------------------------------------------
> The message contains confidential and/or legally privileged
> information and is intended for use by the indicated addressee. If you
> are not the intended addressee: (a) any disclosure, reproduction,
> distribution or action you take because of it is strictly prohibited;
> (b) please return the complete message to the sender; and (c) this
> message is not a solicitation for purchase or sale or an agreement of
> any kind whatsoever that binds the sender.
> ---------------------------------------------------------------------
>