Ah, but I see that I can use the completionTimeout as an attribute; I've
tried it using the special namespace with 2.10.5 and it worked.
Thanks!
--sgp
On Mon, Aug 19, 2013 at 1:32 PM, Scott Parkerson <sc...@parkerson.net>wrote:
> 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.
>>
>
>
