I am trying to use a BridgeComponent UMO with filtering outbound routers to route messages based on one of the message properties. The configuration file for the BridgeComponent is as follows:
<!DOCTYPE mule-configuration PUBLIC "-//MuleSource //DTD mule-configuration XML V1.0//EN" "http://mule.mulesource.org/dtds/mule-configuration.dtd";> <mule-configuration id="Router1" version="1.0"> <description> A component to route messages to the next destination in the message header. Wired to JMS queues. </description> <connector name="jmsConnector" className="org.mule.providers.jms.JmsConnector"> <properties> <property name="specification" value="1.1"/> <property name="connectionFactoryJndiName" value="ConnectionFactory"/> <property name="jndiInitialFactory" value="org.apache.activemq.jndi.ActiveMQInitialContextFactory"/> <map name="connectionFactoryProperties"> <property name="brokerURL" value="tcp://foo:61616"/> </map> </properties> </connector> <transformers> <transformer name="SetMessageRoutingProperties" className="org.oclc.mule.transformers.SetMessageRoutingProperties" returnClass="org.apache.activemq.command.ActiveMQMessage"/> </transformers> <model name="Router1"> <mule-descriptor name="Router" implementation="org.mule.components.simple.BridgeComponent"> <inbound-router> <endpoint address="jms://Q.MODS_IN" transformers="SetMessageRoutingProperties"/> </inbound-router> <outbound-router> <catch-all-strategy className="org.mule.routing.ForwardingCatchAllStrategy"> <endpoint address="jms://error.queue"/> </catch-all-strategy> <router className="org.mule.routing.outbound.FilteringOutboundRouter"> <endpoint address="jms://Q.MOD_TITLE"/> <filter className="org.mule.routing.filters.MessagePropertyFilter" expression="destination=MOD_TITLE"/> </router> <router className="org.mule.routing.outbound.FilteringOutboundRouter"> <endpoint address="jms://Q.MOD_DATE"/> <filter className="org.mule.routing.filters.MessagePropertyFilter" expression="destination=MOD_DATE"/> </router> <router className="org.mule.routing.outbound.FilteringOutboundRouter"> <endpoint address="jms://Q.MODS_OUT"/> <filter className="org.mule.routing.filters.MessagePropertyFilter" expression="destination=MODS_OUT"/> </router> <router className="org.mule.routing.outbound.FilteringOutboundRouter"> <endpoint address="smtp://[EMAIL PROTECTED]"/> <filter expectedType="java.lang.Exception" className="org.mule.routing.filters.PayloadTypeFilter"/> </router> </outbound-router> </mule-descriptor> </model> </mule-configuration> The SetMessageRoutingProperties transformer runs (produces console entries) and returns an instance of org.apache.activemq.command.ActiveMQMessage, which implements javax.jms.Message, but then something goes wrong with the outbound routing, producing the following messages: INFO 2007-01-30 17:43:31,105 [jmsConnector.jmsConnector.dispatchers.dispatcher.1] org.mule.providers.jms.JmsMessageDispatcher: Successfully connected to: jms://error.queue ERROR 2007-01-30 17:43:31,121 [jmsConnector.jmsConnector.dispatchers.dispatcher.1] org.mule.impl.DefaultExceptionStrategy: ************************************************************************ ******** Message : Message is not a JMS message, it is of type "java.lang.String". Check the transformer for this Connector "jmsConnector". Failed to route event via endpoint: [EMAIL PROTECTED], endpointUri=jms://error.queue, transformer=Transformer{name='JMSMessageToObject', returnClass=false, returnClass=false, sourceTypes=[interface javax.jms.Message, interface javax.jms.Message]}, name='jms.error.queue', type='senderAndReceiver', properties={}, transactionConfig=Transaction{factory=null, action=NONE, timeout=30000}, filter=null, deleteUnacceptedMessages=false, initialised=true, securityFilter=null, synchronous=null, initialState=started, createConnector=0, remoteSync=false, remoteSyncTimeout=null, endpointEncoding=null}. Message payload is of type: org.apache.activemq.command.ActiveMQTextMessage Type : org.mule.umo.provider.DispatchException Code : MULE_ERROR-42999 JavaDoc : http://mule.codehaus.org/docs/apidocs/org/mule/umo/provider/DispatchExce ption.html Payload : ActiveMQTextMessage {commandId = 6, responseRequired = true, messageId = ID:devapp1.dev.oclc.org-46621-1170197003418-1:0:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:devapp1.dev.oclc.org-46621-1170197003418-1:0:1:1, destination = queue://Q.MODS_IN, transactionId = null, expiration = 0, timestamp = 1170197003853, arrival = 0, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = [EMAIL PROTECTED], dataStructure = null, redeliveryCounter = 0, size = 0, properties = {destinations=MOD_DATE,MODS_OUT, destination=MOD_TITLE, MULE_SESSION=SUQ9NGFjNWMwZjktYjBiMy0xMWRiLWJmNjgtZjM3ZTY1NzI1OGE2, job_id=devapp1.dev.oclc.org/cdf-mod-client_valpha/20070130-17:43:23.759- 0500, originator=cdf-mod-client_valpha, MULE_ENDPOINT=jms://Q.MODS_IN, origin=devapp1.dev.oclc.org, start_time=20070130-17:43:23.759-0500}, readOnlyProperties = true, readOnlyBody = true, droppable = false, text = [snipped]} ************************************************************************ ******** Exception stack is: 1. Message is not a JMS message, it is of type "java.lang.String". Check the transformer for this Connector "jmsConnector". Failed to route event via endpoint: [EMAIL PROTECTED], endpointUri=jms://error.queue, transformer=Transformer{name='JMSMessageToObject', returnClass=false, returnClass=false, sourceTypes=[interface javax.jms.Message, interface javax.jms.Message]}, name='jms.error.queue', type='senderAndReceiver', properties={}, transactionConfig=Transaction{factory=null, action=NONE, timeout=30000}, filter=null, deleteUnacceptedMessages=false, initialised=true, securityFilter=null, synchronous=null, initialState=started, createConnector=0, remoteSync=false, remoteSyncTimeout=null, endpointEncoding=null}. Message payload is of type: org.apache.activemq.command.ActiveMQTextMessage (org.mule.umo.provider.DispatchException) org.mule.providers.jms.JmsMessageDispatcher:168 (http://mule.codehaus.org/docs/apidocs/org/mule/umo/provider/DispatchExc eption.html) ************************************************************************ ******** Root Exception stack trace: org.mule.umo.provider.DispatchException: Message is not a JMS message, it is of type "java.lang.String". Check the transformer for this Connector "jmsConnector". Failed to route event via endpoint: [EMAIL PROTECTED], endpointUri=jms://error.queue, transformer=Transformer{name='JMSMessageToObject', returnClass=false, returnClass=false, sourceTypes=[interface javax.jms.Message, interface javax.jms.Message]}, name='jms.error.queue', type='senderAndReceiver', properties={}, transactionConfig=Transaction{factory=null, action=NONE, timeout=30000}, filter=null, deleteUnacceptedMessages=false, initialised=true, securityFilter=null, synchronous=null, initialState=started, createConnector=0, remoteSync=false, remoteSyncTimeout=null, endpointEncoding=null}. Message payload is of type: org.apache.activemq.command.ActiveMQTextMessage at org.mule.providers.jms.JmsMessageDispatcher.dispatchMessage(JmsMessageDi spatcher.java:168) at org.mule.providers.jms.JmsMessageDispatcher.doDispatch(JmsMessageDispatc her.java:69) at org.mule.providers.AbstractMessageDispatcher$Worker.run(AbstractMessageD ispatcher.java:592) at org.mule.impl.work.WorkerContext.run(WorkerContext.java:317) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker .runTask(ThreadPoolExecutor.java:650) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker .run(ThreadPoolExecutor.java:675) at java.lang.Thread.run(Thread.java:595) ************************************************************************ ******** I'm not connecting the dots. What have I done wrong? -Jon
