camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bhatt, Shally (GE Healthcare)" <Shally.Bh...@ge.com>
Subject ActiveMQ redelivery
Date Thu, 23 Aug 2012 12:06:12 GMT
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


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