CAMEL-4596: enrich supports dynamic uris.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/fe5960ae Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fe5960ae Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fe5960ae Branch: refs/heads/master Commit: fe5960aef0d8040b651762b6d3423a610f87176d Parents: fe8bf8d Author: Claus Ibsen <[email protected]> Authored: Mon Jul 13 14:19:06 2015 +0200 Committer: Claus Ibsen <[email protected]> Committed: Mon Jul 13 14:19:06 2015 +0200 ---------------------------------------------------------------------- .../org/apache/camel/scala/dsl/SEnrichDefinition.scala | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/fe5960ae/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SEnrichDefinition.scala ---------------------------------------------------------------------- diff --git a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SEnrichDefinition.scala b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SEnrichDefinition.scala index 48a40f5..450fe84 100644 --- a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SEnrichDefinition.scala +++ b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SEnrichDefinition.scala @@ -27,7 +27,10 @@ case class SEnrichDefinition(override val target: EnrichDefinition)(implicit val def aggregationStrategy(strategy: AggregationStrategy) = wrap(target.setAggregationStrategy(strategy)) def aggregationStrategyRef(ref: String) = wrap(target.setAggregationStrategyRef(ref)) - - def resourceRef(ref: String) = wrap(target.setResourceRef(ref)) - def resourceUri(resourceUri: String) = wrap(target.setResourceUri(resourceUri)) + def aggregationStrategyMethodName(name: String) = wrap(target.setAggregationStrategyMethodName(name)) + def aggregationStrategyMethodAllowNull(allowNull: Boolean) = wrap(target.setAggregationStrategyMethodAllowNull(allowNull)) + def aggregateOnException(aggregateOnException: Boolean) = wrap(target.setAggregateOnException(aggregateOnException)) + def shareUnitOfWork() = wrap(target.setShareUnitOfWork(true)) + def cacheSize(size: Integer) = wrap(target.setCacheSize(size)) + }
