Hi I'm trying to use MS SQL or Oracle database as Aggregator persistence repository for MapMessages which have data serialized in protobuf. I'm able to store data in database (both Oracle or MS Sql ) but then i'm getting serialization:
ava.lang.RuntimeException: Error getting key 1 from repository AggregatorDev Caused by: java.io.StreamCorruptedException: invalid type code: 0A Any ideas how to fix this issue ------------------------------------------------------------------- INFO | jvm 1 | 2013/08/08 18:21:27 | WARN | Exception occurred during purge task. This exception will be ignored. INFO | jvm 1 | 2013/08/08 18:21:27 | java.lang.RuntimeException: Error getting key 1 from repository AggregatorDev INFO | jvm 1 | 2013/08/08 18:21:27 | at org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository$2.doInTransaction(JdbcAggregationRepository.java:177) INFO | jvm 1 | 2013/08/08 18:21:27 | at org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository$2.doInTransaction(JdbcAggregationRepository.java:166) INFO | jvm 1 | 2013/08/08 18:21:27 | at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:130) INFO | jvm 1 | 2013/08/08 18:21:27 | at org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository.get(JdbcAggregationRepository.java:166) INFO | jvm 1 | 2013/08/08 18:21:27 | at org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository.get(JdbcAggregationRepository.java:158) INFO | jvm 1 | 2013/08/08 18:21:27 | at org.apache.camel.processor.aggregate.AggregateProcessor$AggregationTimeoutMap.onEviction(AggregateProcessor.java:645) INFO | jvm 1 | 2013/08/08 18:21:27 | at org.apache.camel.processor.aggregate.AggregateProcessor$AggregationTimeoutMap.onEviction(AggregateProcessor.java:616) INFO | jvm 1 | 2013/08/08 18:21:27 | at org.apache.camel.util.DefaultTimeoutMap.purge(DefaultTimeoutMap.java:202) INFO | jvm 1 | 2013/08/08 18:21:27 | at org.apache.camel.processor.aggregate.AggregateProcessor$AggregationTimeoutMap.purge(AggregateProcessor.java:628) INFO | jvm 1 | 2013/08/08 18:21:27 | at org.apache.camel.util.DefaultTimeoutMap.run(DefaultTimeoutMap.java:158) INFO | jvm 1 | 2013/08/08 18:21:27 | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441) INFO | jvm 1 | 2013/08/08 18:21:27 | at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317) INFO | jvm 1 | 2013/08/08 18:21:27 | at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150) INFO | jvm 1 | 2013/08/08 18:21:27 | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98) INFO | jvm 1 | 2013/08/08 18:21:27 | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180) INFO | jvm 1 | 2013/08/08 18:21:27 | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204) INFO | jvm 1 | 2013/08/08 18:21:27 | at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) INFO | jvm 1 | 2013/08/08 18:21:27 | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) INFO | jvm 1 | 2013/08/08 18:21:27 | at java.lang.Thread.run(Thread.java:662) INFO | jvm 1 | 2013/08/08 18:21:27 | Caused by: java.io.StreamCorruptedException: invalid type code: 0A ---------------------------------------------------------------------------------------------------- Details apache-activemq-5.5.1-fuse-03-06 spring-jdbc-3.0.7.RELEASE.jar camel-jdbc-2.8.6.jar camel-sql-2.8.6.jar -- View this message in context: http://camel.465427.n5.nabble.com/Aggregator-Serialization-Exception-tp5737007.html Sent from the Camel - Users mailing list archive at Nabble.com.
