activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: AMQ DeadLetterStrategy Not Being Respected
Date Fri, 23 Aug 2013 14:54:10 GMT
So would save me some time if you just plug your test into my testcase, or
alter my test to fail the way yours is. Then I would be happy to continue
to help.


On Thu, Aug 22, 2013 at 7:59 AM, nezor <kyle.eckhart@oeconnection.com>wrote:

> Mostly I have been using my route which is for a specific use case (jetty
> consumer -> virtual topic -> http4producer). But I just created something
> smaller which I've been testing with.
>
> <bean id="exception" class="java.lang.Exception" />
>
> <camelContext xmlns="http://camel.apache.org/schema/spring">
>   <route id="dlqtest">
>       <from uri="activemq:queue:bar"/>
>       <transacted ref="PROPAGATION_REQUIRES_NEW"/>
>       <to uri="direct:throwexception"/>
>       <onException>
>         <exception>java.lang.Exception</exception>
>         <rollback/>
>       </onException>
>     </route>
>
>     <route id ="throwexception">
>       <from uri="direct:throwexception"/>
>       <throwException ref="exception"/>
>     </route>
> </camelContext>
>
> I can't even get this setup to write to the ActiveMQ.DLQ. The karaf log
> shows the message is rolledback and redelivered (I only have it set to
> redeliver once for testing purposes). After resending once the message is
> removed from queue:bar and goes nowhere. I have tried removing the
> onException clause and many other configurations but nothing seems to be
> working. My configuration for ActiveMQ is fairly standard based on the
> documentation.
>
> <bean id="jmsConnectionFactory"
> class="org.apache.activemq.ActiveMQConnectionFactory">
>   <property name="brokerURL">
>     <value>tcp://localhost:61616</value>
>   </property>
>   <property name="redeliveryPolicy" ref="standardRedeliveryPolicy"/>
> </bean>
>
> <bean id="jmsConfig"
> class="org.apache.camel.component.jms.JmsConfiguration">
>   <property name="connectionFactory" ref="jmsConnectionFactory"/>
>   <property name="cacheLevelName" value="CACHE_CONSUMER" />
>   <property name="concurrentConsumers" value="10"/>
>   <property name="disableTimeToLive" value="true"/>
>   <property name="deliveryPersistent" value="true"/>
>   <property name="explicitQosEnabled" value="true"/>
>   <property name="priority" value="1"/>
>   <property name="transacted" value="true" />
>   <property name="transactionManager" ref="jmsTransactionManager" />
> </bean>
>
> <bean id="activemq"
> class="org.apache.activemq.camel.component.ActiveMQComponent">
>   <property name="configuration" ref="jmsConfig"/>
> </bean>
>
> <bean id="pooledConnectionFactory"
> class="org.apache.activemq.pool.PooledConnectionFactory"
> init-method="start"
> destroy-method="stop">
>   <property name="maxConnections" value="10" />
>   <property name="maximumActive" value="500" />
>   <property name="connectionFactory" ref="jmsConnectionFactory" />
> </bean>
>
> <bean id="standardRedeliveryPolicy"
> class="org.apache.activemq.RedeliveryPolicy">
>   <property name="maximumRedeliveries" value="1" />
>   <property name="redeliveryDelay" value="1000" />
>   <property name="useCollisionAvoidance" value="false"/>
>   <property name="useExponentialBackOff" value="false"/>
> </bean>
>
> <bean id="jmsTransactionManager"
> class="org.springframework.jms.connection.JmsTransactionManager">
>   <property name="connectionFactory" ref="jmsConnectionFactory"/>
> </bean>
>
> <bean id="PROPAGATION_REQUIRES_NEW"
> class="org.apache.camel.spring.spi.SpringTransactionPolicy">
>   <property name="transactionManager" ref="jmsTransactionManager"/>
>   <property name="propagationBehaviorName"
> value="PROPAGATION_REQUIRES_NEW"/>
> </bean>
> <bean id="PROPAGATION_REQUIRED"
> class="org.apache.camel.spring.spi.SpringTransactionPolicy">
>   <property name="transactionManager" ref="jmsTransactionManager"/>
>   <property name="propagationBehaviorName" value="PROPAGATION_REQUIRED"/>
> </bean>
>
> Thank again for the help.
>
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/AMQ-DeadLetterStrategy-Not-Being-Respected-tp4670553p4670580.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message