Hi Shally, Your topic should be discussed in activemq mailing list but not on camel
Regards, Charles On Thu, Aug 23, 2012 at 2:06 PM, Bhatt, Shally (GE Healthcare) < [email protected]> wrote: > Hi,**** > > ** ** > > An overview of the data-flow **** > > ** > **** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > ** ** > > We have an application, that receives messages and sends it to multiple > endpoints.**** > > Before sending to these endpoints, we have activemq which will store the > message, and process the message and then send it to the endpoint. We have > noticed that the movement the message is being picked up for processing, it > gets dequeued from activemq.If the process fails or the endpoint is not > reachable, the message is lost. We want that message should be retained in > the queue until the message is consumed by the endpoint successfully.**** > > ** ** > > We tried setting the redeliverypolicy in our configuration file as below, > but it did not work:**** > > *<bean id="jmsConnectionFactory" > class="org.apache.activemq.ActiveMQConnectionFactory"> > <property name="brokerURL" value="tcp://localhost:61616" /> > <property name="redeliveryPolicy" ref="redeliveryPolicy" /> > </bean> > > <bean id="redeliveryPolicy" class="org.apache.activemq.RedeliveryPolicy"> > <property name="maximumRedeliveries" value="1" /> > </bean> > > <bean id="pooledConnectionFactory" > class="org.apache.activemq.pool.PooledConnectionFactory"> > <property name="maxConnections" value="8" /> > <property name="maximumActive" value="500" /> > <property name="connectionFactory" ref="jmsConnectionFactory" /> > </bean> > <bean id="jmsConfig" > class="org.apache.camel.component.jms.JmsConfiguration"> > <property name="connectionFactory" ref="pooledConnectionFactory" /> > <property name="transacted" value="false" /> > <property name="concurrentConsumers" value="10" /> > > </bean> > <bean id="activemq" > class="org.apache.activemq.camel.component.ActiveMQComponent"> > <property name="configuration" ref="jmsConfig" /> > </bean>** * > > * * > > Kindly help us to figure out what configuration we need to make, to get it > working.**** > > ** ** > > Regards,**** > > Shally**** > -- Charles Moulliard Apache Committer / Sr. Pr. Consultant at FuseSource.com Twitter : @cmoulliard Blog : http://cmoulliard.blogspot.com
