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
