camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From piotrsl <p.sliwin...@gmail.com>
Subject Aggregator message redelivery issues
Date Mon, 29 Jul 2013 16:21:06 GMT
Hi Guys 
I'm struggling with the following issue and maybe you will be able to help
me.

Recently i have noticed that messages which are aggregated by camel
Aggregator2 with hawtdb persistence store are lost because the following
exception

2013-07-29 10:02:18,478 | ERROR | Failed delivery for exchangeId:
ID-UK1DAAMQ001VA-57144-1374756544748-0-9284. Exhausted after delivery
attempt: 1 caught: java.lang.RuntimeException: Error getting key 125AAA from
repository futuresAggregatorRepository |
org.apache.camel.processor.DefaultErrorHandler | Camel (camel) thread #11 -
JmsConsumer[GC.Canonical.ClearedTrade.Tempest.Test]
java.lang.RuntimeException: Error getting key 125AAA  from repository
AggregatorRepository
	at
org.apache.camel.component.hawtdb.HawtDBAggregationRepository.get(HawtDBAggregationRepository.java:164)
.....
Caused by: java.io.IOException
	at java.nio.MappedByteBuffer.force0(Native Method)
	at java.nio.MappedByteBuffer.force(MappedByteBuffer.java:154)
	at
org.fusesource.hawtdb.internal.io.MemoryMappedFile.sync(MemoryMappedFile.java:255)
	at
org.fusesource.hawtdb.internal.page.HawtTxPageFile.syncBatches(HawtTxPageFile.java:656)
	at
org.fusesource.hawtdb.internal.page.HawtTxPageFile.flush(HawtTxPageFile.java:551)
	at
org.apache.camel.component.hawtdb.HawtDBFile.doExecute(HawtDBFile.java:165)
	at
org.apache.camel.component.hawtdb.HawtDBFile.execute(HawtDBFile.java:113)
	at
org.apache.camel.component.hawtdb.HawtDBAggregationRepository.get(HawtDBAggregationRepository.java:144)

------------------------------------------------------------------------------------------------------
CAMEL

<bean id="AggregatorRepository"
class="org.apache.camel.component.hawtdb.HawtDBAggregationRepository">
		<property name="repositoryName" value="AggregatorRepository"/>
		<property name="persistentFileName"
value="\\max\apps\AggregatorRepository\DEV\AggregatorRepository.dat"/>		
		<property name="useRecovery" value="true"/>
		<property name="recoveryInterval" value="60000"/>
		<property name="maximumRedeliveries" value="240"/>
		<property name="deadLetterUri" value="jms:queue:DLQ.GC.Aggregator.Dev"/>		
</bean>

----------------------------------------------------------------------------------------------------


Do you know what might be causing java.io.IOException
And why redelivery mechanism didn't work


Details
apache-activemq-5.5.1-fuse-03-06
hawtdb-1.6.jar
hawtbuf-1.9.jar
camel-hawtdb-2.8.6.jar





--
View this message in context: http://camel.465427.n5.nabble.com/Aggregator-message-redelivery-issues-tp5736445.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message