Babak,
I'm not sure this will help, as the value I'm trying to replace is not an
attribute, but a child element (see <completionTimeout> element below:
<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>
--sgp
On Mon, Aug 19, 2013 at 12:53 PM, Babak Vahdat
<babak.vah...@swissonline.ch>wrote:
> 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.
>
