Hi,

I have a camel application which reads messages from rabbit-MQ, zip them and
write it to out file successfully. After executing 3-4 days, it appears that
it does not pick up messages from rabbit MQ and messages starts queuing up
on rabbit MQ. Finally, I need to re-start the application and then every
thing gets working fine. During this phase, no abnormal behavior of CPU or
Memory observed. I am not sure what the issue is. Can somebody please point
me what could be the cause of such behavior. 

I would appreciate any help in the matter. Thanks in advance. 

Here is my configuration file.

        
<bean id="zipFormat"
class="org.apache.camel.dataformat.zipfile.ZipFileDataFormat" /> 

<camelContext id="AggregatorContext"
xmlns="http://camel.apache.org/schema/spring";>
        <onException useOriginalMessage="true">
                <exception>java.lang.Exception</exception>
                <redeliveryPolicy maximumRedeliveries="6" redeliveryDelay="10"
logHandled="true" asyncDelayedRedelivery="true" />
                <handled>
                        <constant>true</constant>
                </handled>
                <to uri="file:{{failure.dir}}"/>
        </onException>
        
        <route id="AggregatorQueue_Route">
                <from
uri="rabbitmq:{{rabbitmq.exchangeName}}:{{rabbitmq.queueName}}?type={{rabbitmq.exchangeType}}&amp;routingKey={{rabbitmq.routingKey}}&amp;durable=true&amp;autoDelete=false&amp;preFetchCount={{rabbitmq.prefetchCount}}"/>
                <marshal ref="zipFormat"/>  
                <to
uri="file:{{outfile.dir}}?noop=true&amp;doneFileName=$simple{file:name:noext}.done"
/>
        </route>
</camelContext>






--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-router-stops-reading-messages-from-rabbitMQ-tp5756633.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to