« Return to Thread: JMS Reply To Issue

Re: JMS Reply To Issue

by Richard Holt :: Rate this Message:

Reply to Author | View in Thread

Unfortunately even though the test scenario now works it isn't working in my application.

Inbound Transformers run after a ReplyToHandler is set by SEDAService, so i cannot intercept and remove the ReplyTo set by Mule A from within Mule B.

Is there anything which runs prior to the call to construct this ReplyToHandler which i can use to strip the headers?

Regards,

Richard


Here is the configuration again,

<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns="http://www.mulesource.org/schema/mule/core/2.1"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:spring="http://www.springframework.org/schema/beans"
        xmlns:jms="http://www.mulesource.org/schema/mule/jms/2.1"
        xmlns:jbossts="http://www.mulesource.org/schema/mule/jbossts/2.1"
        xmlns:file="http://www.mulesource.org/schema/mule/file/2.1"
        xmlns:management="http://www.mulesource.org/schema/mule/management/2.1"
        xmlns:context="http://www.springframework.org/schema/context"
        xsi:schemaLocation="http://www.mulesource.org/schema/mule/core/2.1 http://www.mulesource.org/schema/mule/core/2.1/mule.xsd
                http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.1.xsd
                http://www.mulesource.org/schema/mule/jms/2.1 http://www.mulesource.org/schema/mule/jms/2.1/mule-jms.xsd
                http://www.mulesource.org/schema/mule/management/2.1 http://www.mulesource.org/schema/mule/management/2.1/mule-management.xsd
                http://www.mulesource.org/schema/mule/jbossts/2.1 http://www.mulesource.org/schema/mule/jbossts/2.1/mule-jbossts.xsd   
                http://www.mulesource.org/schema/mule/file/2.1 http://www.mulesource.org/schema/mule/file/2.1/mule-file.xsd">
               
        <file:connector name="fileConnector" autoDelete="true" streaming="false"/>

        <jms:activemq-connector name="localJmsConnector" specification="1.1"
                acknowledgementMode="AUTO_ACKNOWLEDGE" recoverJmsConnections="true" persistentDelivery="true">
        </jms:activemq-connector>

        <model name="testModel">
                <service name="testService">
                  <inbound>
                    <file:inbound-endpoint path="c:/data/in" moveToDirectory="c:/save"/>
                  </inbound>
                  <outbound>
                  <pass-through-router>
                    <jms:outbound-endpoint queue="test1.queue" connector-ref="localJmsConnector">
                    <jms:object-to-jmsmessage-transformer/>
                    </jms:outbound-endpoint>
                    </pass-through-router>
                  </outbound>
                </service>

                <service name="testService1">
                  <inbound>
                    <jms:inbound-endpoint queue="test1.queue" connector-ref="localJmsConnector"/>
                  </inbound>
                  <outbound>
                        <custom-outbound-router class="com.acme.JmsRecipientList"/>
                  </outbound>
                </service>

                <service name="testService2">
                  <inbound>
                    <jms:inbound-endpoint queue="test2.queue" connector-ref="localJmsConnector"/>
                  </inbound>
                  <outbound>
                  <pass-through-router>
                                <file:outbound-endpoint path="c:/data/out2" connector-ref="fileConnector"/>
                  </pass-through-router>
                  </outbound>
                </service>

                <service name="testService3">
                  <inbound>
                    <jms:inbound-endpoint queue="test3.queue" connector-ref="localJmsConnector"/>
                  </inbound>
                  <outbound>
                  <pass-through-router>
                                <file:outbound-endpoint path="c:/data/out3" connector-ref="fileConnector"/>
                  </pass-through-router>
                  </outbound>
                </service>
        </model>
</mule>

 « Return to Thread: JMS Reply To Issue