activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mtod <m...@thetods.net>
Subject Re: Help with a Failover testing that shows missing messages
Date Mon, 22 Feb 2016 15:05:58 GMT
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.

Mime
View raw message