Thanks for the reply.

The messages were missing across all clients.

Not sure what you referring to about Camel Ack mode.

I  add the Camel file using an import in the ActiveMQ file
<broker>
...
</broker>
<import resource="ESBRoute1.xml"/> 

Here is my Camel Code:


<beans
  xmlns="http://www.springframework.org/schema/beans";
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
  xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
  http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd";>

    
    <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <value>file:${activemq.conf}/credentials.properties</value>
        </property>
    </bean>
        
        <bean id="myDeadLetterErrorHandler"
class="org.apache.camel.builder.DeadLetterChannelBuilder">
                <property name="deadLetterUri" value="jms:queue:dead"/>
                <property name="redeliveryPolicy" 
ref="myRedeliveryPolicyConfig"/>
        </bean>
 
        <bean id="myRedeliveryPolicyConfig"
class="org.apache.camel.processor.RedeliveryPolicy">
                <property name="maximumRedeliveries" value="3"/>
                <property name="redeliveryDelay" value="5000"/>
        </bean>
                
        <camelContext id="esbRoute1" trace="true" streamCache="true"
xmlns="http://camel.apache.org/schema/spring";
xmlns:km="http://xsdrepo.foundationmedicine.com/messaging/esb";> 
                <route errorHandlerRef="myDeadLetterErrorHandler">
                        <from uri="activemq:queue:esb.*"/>
                        
                        <doTry>                         
                                <to
uri="validator:http://xsdrepo.foundationmedicine.com/messaging/esb/ESBMessageV3.xsd"/>
                                <setHeader headerName="Route1">                 
        
                                        <xpath
resultType="String">/km:FMIMessage/km:Header/km:Route/text()</xpath>
                                </setHeader>
                                <recipientList delimiter="false">
                                        <header>Route1</header>
                                </recipientList>
                                <doCatch>
                                        
<exception>org.apache.camel.ValidationException</exception>                     
                                                        
                                        <onWhen>
                                                
<simple>${exception.message}</simple>
                                        </onWhen>
                                        <to 
uri="activemq:queue:invalid.schema"/>
                                </doCatch>
                        </doTry>
                </route>                
        </camelContext>
</beans>



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4707937.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to