This Camel route doesn’t appear to use any sort of transactional control - i.e. CLIENT_ACKNOWLEDGE or SESSION_TRANSACTED.
Try adding “transacted=true” in your consuming URI - <from uri="activemq:queue:esb.*?transacted=true"/> > On Feb 22, 2016, at 8:05 AM, mtod <m...@thetods.net> wrote: > > 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.
