This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 9b609a1a18e CAMEL-21406: camel-sql - Fix so configuring
RowMapperFactory can refer to a bean or class
9b609a1a18e is described below
commit 9b609a1a18e17957d8cd05aebfd42c1fe5d3afb5
Author: Claus Ibsen <[email protected]>
AuthorDate: Wed Oct 30 13:00:30 2024 +0100
CAMEL-21406: camel-sql - Fix so configuring RowMapperFactory can refer to a
bean or class
---
.../src/main/java/org/apache/camel/component/sql/SqlComponent.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java
b/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java
index 66d2d2f4e32..8a70d4c5a1e 100644
---
a/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java
+++
b/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java
@@ -93,7 +93,8 @@ public class SqlComponent extends HealthCheckComponent {
if (onConsumeBatchComplete != null && usePlaceholder) {
onConsumeBatchComplete =
onConsumeBatchComplete.replaceAll(parameterPlaceholderSubstitute, "?");
}
- RowMapperFactory factory = getAndRemoveParameter(parameters,
"rowMapperFactory", RowMapperFactory.class);
+ RowMapperFactory factory
+ = getAndRemoveOrResolveReferenceParameter(parameters,
"rowMapperFactory", RowMapperFactory.class);
if (factory == null) {
factory = rowMapperFactory;
}