You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Michael Szalay <mi...@basis06.ch> on 2012/09/20 13:28:59 UTC
Setting dynamic completionInterval in aggregator
Hi all
How can I set a dynamic completionInterval in an aggregator?
I can set the values for timeout and size using headers like this
<completionPredicate>
<simple>...</simple>
</completionPredicate>
<completionTimeout>
<simple>${header.AggregateCompletionTimeout}</simple>
</completionTimeout>
<completionSize>
<simple>${header.AggregateCompletionSize}</simple>
</completionSize>
Why isn't there an analogous element for <completionInterval> here?
Invalid content was found starting with element 'completionInterval'. One of '{"http://camel.apache.org/schema/blueprint":onException, "http://camel.apache.org/schema/blueprint":when, "http://camel.apache.org/schema/blueprint":onCompletion, "http://camel.apache.org/schema/blueprint":intercept, "http://camel.apache.org/schema/blueprint":interceptFrom, "http://camel.apache.org/schema/blueprint":interceptToEndpoint, "http://camel.apache.org/schema/blueprint":route, "http://camel.apache.org/schema/blueprint":aop, "http://camel.apache.org/schema/blueprint":aggregate, "http://camel.apache.org/schema/blueprint":bean, "http://camel.apache.org/schema/blueprint":doCatch, "http://camel.apache.org/schema/blueprint":choice, "http://camel.apache.org/schema/blueprint":otherwise, "http://camel.apache.org/schema/blueprint":convertBodyTo, "http://camel.apache.org/schema/blueprint":delay, "http://camel.apache.org/schema/blueprint":dynamicRouter, "http://camel.apache.org/schema/blueprint":enrich, "http://camel.apache.org/schema/blueprint":filter, "http://camel.apache.org/schema/blueprint":doFinally, "http://camel.apache.org/schema/blueprint":idempotentConsumer, "http://camel.apache.org/schema/blueprint":inOnly, "http://camel.apache.org/schema/blueprint":inOut, "http://camel.apache.org/schema/blueprint":loadBalance, "http://camel.apache.org/schema/blueprint":log, "http://camel.apache.org/schema/blueprint":loop, "http://camel.apache.org/schema/blueprint":marshal, "http://camel.apache.org/schema/blueprint":multicast, "http://camel.apache.org/schema/blueprint":pipeline, "http://camel.apache.org/schema/blueprint":policy, "http://camel.apache.org/schema/blueprint":pollEnrich, "http://camel.apache.org/schema/blueprint":process, "http://camel.apache.org/schema/blueprint":recipientList, "http://camel.apache.org/schema/blueprint":removeHeader, "http://camel.apache.org/schema/blueprint":removeHeaders, "http://camel.apache.org/schema/blueprint":removeProperty, "http://camel.apache.org/schema/blueprint":resequence, "http://camel.apache.org/schema/blueprint":rollback, "http://camel.apache.org/schema/blueprint":routingSlip, "http://camel.apache.org/schema/blueprint":sample, "http://camel.apache.org/schema/blueprint":setBody, "http://camel.apache.org/schema/blueprint":setExchangePattern, "http://camel.apache.org/schema/blueprint":setFaultBody, "http://camel.apache.org/schema/blueprint":setHeader, "http://camel.apache.org/schema/blueprint":setOutHeader, "http://camel.apache.org/schema/blueprint":setProperty, "http://camel.apache.org/schema/blueprint":sort, "http://camel.apache.org/schema/blueprint":split, "http://camel.apache.org/schema/blueprint":stop, "http://camel.apache.org/schema/blueprint":threads, "http://camel.apache.org/schema/blueprint":throttle, "http://camel.apache.org/schema/blueprint":throwException, "http://camel.apache.org/schema/blueprint":to, "http://camel.apache.org/schema/blueprint":transacted, "http://camel.apache.org/schema/blueprint":transform, "http://camel.apache.org/schema/blueprint":doTry, "http://camel.apache.org/schema/blueprint":unmarshal, "http://camel.apache.org/schema/blueprint":validate, "http://camel.apache.org/schema/blueprint":wireTap}' is expected.
at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.createSAXParseException(ErrorHandlerWrapper.java:195) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.error(ErrorHandlerWrapper.java:131) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:384) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:318) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator$XSIErrorReporter.reportError(XMLSchemaValidator.java:417) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.reportSchemaError(XMLSchemaValidator.java:3182) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.handleStartElement(XMLSchemaValidator.java:1806) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.startElement(XMLSchemaValidator.java:705) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.jaxp.validation.DOMValidatorHelper.beginNode(DOMValidatorHelper.java:273) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.jaxp.validation.DOMValidatorHelper.validate(DOMValidatorHelper.java:240) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.jaxp.validation.DOMValidatorHelper.validate(DOMValidatorHelper.java:186) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.jaxp.validation.ValidatorImpl.validate(ValidatorImpl.java:104) ~[na:1.6.0_30]
at javax.xml.validation.Validator.validate(Validator.java:127) ~[na:1.6.0_30]
at org.apache.aries.blueprint.container.Parser.validate(Parser.java:285) ~[org.apache.aries.blueprint-0.3.jar:0.3]
... 10 common frames omitted
I'm using camel 2.10.1.
Regards Michael
Re: Setting dynamic completionInterval in aggregator
Posted by Claus Ibsen <cl...@gmail.com>.
Thats not possible. The completion interval and timeout are fixed values.
On Thu, Sep 20, 2012 at 1:28 PM, Michael Szalay
<mi...@basis06.ch> wrote:
> Hi all
>
> How can I set a dynamic completionInterval in an aggregator?
> I can set the values for timeout and size using headers like this
>
> <completionPredicate>
> <simple>...</simple>
> </completionPredicate>
> <completionTimeout>
> <simple>${header.AggregateCompletionTimeout}</simple>
> </completionTimeout>
> <completionSize>
> <simple>${header.AggregateCompletionSize}</simple>
> </completionSize>
>
> Why isn't there an analogous element for <completionInterval> here?
>
> Invalid content was found starting with element 'completionInterval'. One of '{"http://camel.apache.org/schema/blueprint":onException, "http://camel.apache.org/schema/blueprint":when, "http://camel.apache.org/schema/blueprint":onCompletion, "http://camel.apache.org/schema/blueprint":intercept, "http://camel.apache.org/schema/blueprint":interceptFrom, "http://camel.apache.org/schema/blueprint":interceptToEndpoint, "http://camel.apache.org/schema/blueprint":route, "http://camel.apache.org/schema/blueprint":aop, "http://camel.apache.org/schema/blueprint":aggregate, "http://camel.apache.org/schema/blueprint":bean, "http://camel.apache.org/schema/blueprint":doCatch, "http://camel.apache.org/schema/blueprint":choice, "http://camel.apache.org/schema/blueprint":otherwise, "http://camel.apache.org/schema/blueprint":convertBodyTo, "http://camel.apache.org/schema/blueprint":delay, "http://camel.apache.org/schema/blueprint":dynamicRouter, "http://camel.apache.org/schema/blueprint":enrich, "http://camel.apache.org/schema/blueprint":filter, "http://camel.apache.org/schema/blueprint":doFinally, "http://camel.apache.org/schema/blueprint":idempotentConsumer, "http://camel.apache.org/schema/blueprint":inOnly, "http://camel.apache.org/schema/blueprint":inOut, "http://camel.apache.org/schema/blueprint":loadBalance, "http://camel.apache.org/schema/blueprint":log, "http://camel.apache.org/schema/blueprint":loop, "http://camel.apache.org/schema/blueprint":marshal, "http://camel.apache.org/schema/blueprint":multicast, "http://camel.apache.org/schema/blueprint":pipeline, "http://camel.apache.org/schema/blueprint":policy, "http://camel.apache.org/schema/blueprint":pollEnrich, "http://camel.apache.org/schema/blueprint":process, "http://camel.apache.org/schema/blueprint":recipientList, "http://camel.apache.org/schema/blueprint":removeHeader, "http://camel.apache.org/schema/blueprint":removeHeaders, "http://camel.apache.org/schema/blueprint":removeProperty, "http://camel.apache.org/schema/blueprint":resequence, "http://camel.apache.org/schema/blueprint":rollback, "http://camel.apache.org/schema/blueprint":routingSlip, "http://camel.apache.org/schema/blueprint":sample, "http://camel.apache.org/schema/blueprint":setBody, "http://camel.apache.org/schema/blueprint":setExchangePattern, "http://camel.apache.org/schema/blueprint":setFaultBody, "http://camel.apache.org/schema/blueprint":setHeader, "http://camel.apache.org/schema/blueprint":setOutHeader, "http://camel.apache.org/schema/blueprint":setProperty, "http://camel.apache.org/schema/blueprint":sort, "http://camel.apache.org/schema/blueprint":split, "http://camel.apache.org/schema/blueprint":stop, "http://camel.apache.org/schema/blueprint":threads, "http://camel.apache.org/schema/blueprint":throttle, "http://camel.apache.org/schema/blueprint":throwException, "http://camel.apache.org/schema/blueprint":to, "http://camel.apache.org/schema/blueprint":transacted, "http://camel.apache.org/schema/blueprint":transform, "http://camel.apache.org/schema/blueprint":doTry, "http://camel.apache.org/schema/blueprint":unmarshal, "http://camel.apache.org/schema/blueprint":validate, "http://camel.apache.org/schema/blueprint":wireTap}' is expected.
> at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.createSAXParseException(ErrorHandlerWrapper.java:195) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.error(ErrorHandlerWrapper.java:131) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:384) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:318) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator$XSIErrorReporter.reportError(XMLSchemaValidator.java:417) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.reportSchemaError(XMLSchemaValidator.java:3182) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.handleStartElement(XMLSchemaValidator.java:1806) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.startElement(XMLSchemaValidator.java:705) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.jaxp.validation.DOMValidatorHelper.beginNode(DOMValidatorHelper.java:273) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.jaxp.validation.DOMValidatorHelper.validate(DOMValidatorHelper.java:240) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.jaxp.validation.DOMValidatorHelper.validate(DOMValidatorHelper.java:186) ~[na:1.6.0_30]
> at com.sun.org.apache.xerces.internal.jaxp.validation.ValidatorImpl.validate(ValidatorImpl.java:104) ~[na:1.6.0_30]
> at javax.xml.validation.Validator.validate(Validator.java:127) ~[na:1.6.0_30]
> at org.apache.aries.blueprint.container.Parser.validate(Parser.java:285) ~[org.apache.aries.blueprint-0.3.jar:0.3]
> ... 10 common frames omitted
>
> I'm using camel 2.10.1.
>
> Regards Michael
--
Claus Ibsen
-----------------
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cibsen@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Fwd: Setting dynamic completionInterval in aggregator
Posted by Michael Szalay <mi...@basis06.ch>.
Hi all
How can I set a dynamic completionInterval in an aggregator?
I can set the values for timeout and size using headers like this
<completionPredicate>
<simple>...</simple>
</completionPredicate>
<completionTimeout>
<simple>${header.AggregateCompletionTimeout}</simple>
</completionTimeout>
<completionSize>
<simple>${header.AggregateCompletionSize}</simple>
</completionSize>
Why isn't there an analogous element for <completionInterval> here?
I'm using camel 2.10.1.
Regards Michael
Invalid content was found starting with element 'completionInterval'. One of '{"http://camel.apache.org/schema/blueprint":onException, "http://camel.apache.org/schema/blueprint":when, "http://camel.apache.org/schema/blueprint":onCompletion, "http://camel.apache.org/schema/blueprint":intercept, "http://camel.apache.org/schema/blueprint":interceptFrom, "http://camel.apache.org/schema/blueprint":interceptToEndpoint, "http://camel.apache.org/schema/blueprint":route, "http://camel.apache.org/schema/blueprint":aop, "http://camel.apache.org/schema/blueprint":aggregate, "http://camel.apache.org/schema/blueprint":bean, "http://camel.apache.org/schema/blueprint":doCatch, "http://camel.apache.org/schema/blueprint":choice, "http://camel.apache.org/schema/blueprint":otherwise, "http://camel.apache.org/schema/blueprint":convertBodyTo, "http://camel.apache.org/schema/blueprint":delay, "http://camel.apache.org/schema/blueprint":dynamicRouter, "http://camel.apache.org/schema/blueprint":enrich, "http://camel.apache.org/schema/blueprint":filter, "http://camel.apache.org/schema/blueprint":doFinally, "http://camel.apache.org/schema/blueprint":idempotentConsumer, "http://camel.apache.org/schema/blueprint":inOnly, "http://camel.apache.org/schema/blueprint":inOut, "http://camel.apache.org/schema/blueprint":loadBalance, "http://camel.apache.org/schema/blueprint":log, "http://camel.apache.org/schema/blueprint":loop, "http://camel.apache.org/schema/blueprint":marshal, "http://camel.apache.org/schema/blueprint":multicast, "http://camel.apache.org/schema/blueprint":pipeline, "http://camel.apache.org/schema/blueprint":policy, "http://camel.apache.org/schema/blueprint":pollEnrich, "http://camel.apache.org/schema/blueprint":process, "http://camel.apache.org/schema/blueprint":recipientList, "http://camel.apache.org/schema/blueprint":removeHeader, "http://camel.apache.org/schema/blueprint":removeHeaders, "http://camel.apache.org/schema/blueprint":removeProperty, "http://camel.apache.org/schema/blueprint":resequence, "http://camel.apache.org/schema/blueprint":rollback, "http://camel.apache.org/schema/blueprint":routingSlip, "http://camel.apache.org/schema/blueprint":sample, "http://camel.apache.org/schema/blueprint":setBody, "http://camel.apache.org/schema/blueprint":setExchangePattern, "http://camel.apache.org/schema/blueprint":setFaultBody, "http://camel.apache.org/schema/blueprint":setHeader, "http://camel.apache.org/schema/blueprint":setOutHeader, "http://camel.apache.org/schema/blueprint":setProperty, "http://camel.apache.org/schema/blueprint":sort, "http://camel.apache.org/schema/blueprint":split, "http://camel.apache.org/schema/blueprint":stop, "http://camel.apache.org/schema/blueprint":threads, "http://camel.apache.org/schema/blueprint":throttle, "http://camel.apache.org/schema/blueprint":throwException, "http://camel.apache.org/schema/blueprint":to, "http://camel.apache.org/schema/blueprint":transacted, "http://camel.apache.org/schema/blueprint":transform, "http://camel.apache.org/schema/blueprint":doTry, "http://camel.apache.org/schema/blueprint":unmarshal, "http://camel.apache.org/schema/blueprint":validate, "http://camel.apache.org/schema/blueprint":wireTap}' is expected.
at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.createSAXParseException(ErrorHandlerWrapper.java:195) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.error(ErrorHandlerWrapper.java:131) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:384) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:318) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator$XSIErrorReporter.reportError(XMLSchemaValidator.java:417) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.reportSchemaError(XMLSchemaValidator.java:3182) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.handleStartElement(XMLSchemaValidator.java:1806) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.startElement(XMLSchemaValidator.java:705) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.jaxp.validation.DOMValidatorHelper.beginNode(DOMValidatorHelper.java:273) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.jaxp.validation.DOMValidatorHelper.validate(DOMValidatorHelper.java:240) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.jaxp.validation.DOMValidatorHelper.validate(DOMValidatorHelper.java:186) ~[na:1.6.0_30]
at com.sun.org.apache.xerces.internal.jaxp.validation.ValidatorImpl.validate(ValidatorImpl.java:104) ~[na:1.6.0_30]
at javax.xml.validation.Validator.validate(Validator.java:127) ~[na:1.6.0_30]
at org.apache.aries.blueprint.container.Parser.validate(Parser.java:285) ~[org.apache.aries.blueprint-0.3.jar:0.3]
... 10 common frames omitted