Hi Can you try upgrading to 2.10.5, see the blue box here about the xs:int type attribute when OSGi Blueprint is in use:
http://camel.apache.org/using-propertyplaceholder.html#UsingPropertyPlaceholder-UsingpropertyplaceholdersforanykindofattributeintheXMLDSL Babak Scott Parkerson-4 wrote > I'm using Camel 2.10.4 with my routes defined in Blueprint. I'm trying to > use a property placeholder to configure the completionTimeout for my > aggregator, and it's complaining: > > Camel (postingResultsCamelContext) thread #6 - seda://start ERROR > [org.apache.camel.processor.DefaultErrorHandler] - Failed delivery for > (MessageId: ID-elysium-local-64760-1376927985149-0-1 on ExchangeId: > ID-elysium-local-64760-1376927985149-0-6). Exhausted after delivery > attempt: 1 caught: org.apache.camel.TypeConversionException: Error during > type conversion from type: java.lang.String to the required type: > java.lang.Long with value {{processor.posting.aggregation_timeout_millis}} > due java.lang.NumberFormatException: For input string: > "{{processor.posting.aggregation_timeout_millis}}" > org.apache.camel.TypeConversionException: Error during type conversion > from > type: java.lang.String to the required type: java.lang.Long with value > {{processor.posting.aggregation_timeout_millis}} due > java.lang.NumberFormatException: For input string: > "{{processor.posting.aggregation_timeout_millis}}" > at > org.apache.camel.impl.converter.BaseTypeConverterRegistry.convertTo(BaseTypeConverterRegistry.java:126) > at > org.apache.camel.core.osgi.OsgiTypeConverter.convertTo(OsgiTypeConverter.java:102) > at > org.apache.camel.support.ExpressionAdapter.evaluate(ExpressionAdapter.java:37) > at > org.apache.camel.builder.SimpleBuilder.evaluate(SimpleBuilder.java:82) > at > org.apache.camel.processor.aggregate.AggregateProcessor.isCompleted(AggregateProcessor.java:333) > at > org.apache.camel.processor.aggregate.AggregateProcessor.doAggregation(AggregateProcessor.java:258) > at > org.apache.camel.processor.aggregate.AggregateProcessor.process(AggregateProcessor.java:201) > at > org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:334) > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220) > at > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:308) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:334) > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220) > at > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150) > at > org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:571) > at > org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:504) > at > org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:213) > at org.apache.camel.processor.Splitter.process(Splitter.java:98) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:334) > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220) > at > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:308) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:117) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) > at > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150) > at > org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117) > at > org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:275) > at > org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:183) > at > org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:139) > at > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) > at java.lang.Thread.run(Thread.java:680) > Caused by: org.apache.camel.RuntimeCamelException: > java.lang.NumberFormatException: For input string: > "{{processor.posting.aggregation_timeout_millis}}" > at > org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1316) > at > org.apache.camel.util.ObjectHelper.invokeMethod(ObjectHelper.java:962) > at > org.apache.camel.impl.converter.StaticMethodTypeConverter.convertTo(StaticMethodTypeConverter.java:47) > at > org.apache.camel.impl.converter.BaseTypeConverterRegistry.doConvertTo(BaseTypeConverterRegistry.java:253) > at > org.apache.camel.impl.converter.BaseTypeConverterRegistry.convertTo(BaseTypeConverterRegistry.java:111) > ... 59 more > Caused by: java.lang.NumberFormatException: For input string: > "{{processor.posting.aggregation_timeout_millis}}" > at > java.lang.NumberFormatException.forInputString(NumberFormatException.java:48) > at java.lang.Long.parseLong(Long.java:410) > at java.lang.Long.valueOf(Long.java:525) > at > org.apache.camel.converter.ObjectConverter.toLong(ObjectConverter.java:255) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) > at java.lang.reflect.Method.invoke(Method.java:597) > at > org.apache.camel.util.ObjectHelper.invokeMethod(ObjectHelper.java:958) > ... 62 more > > Here's my route: > <route id="PostingResults.HANDLER"> > > <from > uri="activemq:{{messaging.jms.namespace}}.POSTING_RESULT_HANDLER" /> > > <log > logName="com.ateb.messaging.myx.processor_posting.CamelRoutes" > loggingLevel="DEBUG" message="${in.header.CamelFileNameOnly}: > ATEB_FILETYPE-> > ${in.header.ATEB_FILETYPE}, > ATEB_CLIENT_ID->${in.header.ATEB_CLIENT_ID}, > ATEB_FILENAME_TIMESTAMP->${in.header.ATEB_FILENAME_TIMESTAMP}"/> > > <choice> > > <when> > > <simple> > ${in.header.ATEB_FILETYPE} == > 'POST_REQ' > </simple> > > <unmarshal ref="postingRequestBeanIO" /> > > </when> > > <when> > > <simple> > ${in.header.ATEB_FILETYPE} == > 'POST_RSLT' > </simple> > > <unmarshal ref="postingResultBeanIO" /> > > </when> > > <otherwise> > > <log > logName="com.ateb.messaging.myx.posting_results.CamelRoutes" > loggingLevel="WARN" message="${in.header.CamelFileNameOnly}: Unhandled > ATEB_FILETYPE ${in.header.ATEB_FILETYPE}, dropping"/> > > <stop/> > > </otherwise> > > </choice> > > <split> > > <simple> > ${body} > </simple> > > <aggregate aggregationRepositoryRef="aggregatorRepository" > > strategyRef="postingRequestResultAggregationStrategy"> > > <correlationExpression> > > <simple> > ${in.header.ATEB_CLIENT_ID}-${body.clientStoreId}-${body.rxNumber}-${in.header.ATEB_FILENAME_DATESTAMP} > </simple> > > </correlationExpression> > > <completionPredicate> > > <simple> > ${in.body.isComplete} > </simple> > > </completionPredicate> > > <completionTimeout> > > <constant> > {{processor.posting.aggregation_timeout_millis}} > </constant> > > </completionTimeout> > > <filter> > > <simple> > ${in.header.CamelAggregatedCompletedBy} == > 'timeout' > </simple> > > <log > logName="com.ateb.messaging.myx.posting_results.CamelRoutes" > loggingLevel="WARN" message="${in.header.CamelFileNameOnly}: > ${in.header.ATEB_CLIENT_ID}-${body.clientStoreId}-${body.rxNumber}-${in.header.ATEB_FILENAME_DATESTAMP}] > Timed out waiting for aggregation"/> > > <stop /> > > </filter> > > <to uri="bean:postResults" /> > > </aggregate> > > </split> > > </route> > I saw in the docs that there's a custom namespace for using integer > properties in spring; do I need to do this for blueprint as well? Does it > even work for blueprint? > > --sgp -- View this message in context: http://camel.465427.n5.nabble.com/Property-Placeholder-for-Aggregation-Completion-Timeout-Value-in-Blueprint-tp5737523p5737524.html Sent from the Camel - Users mailing list archive at Nabble.com.
