This is an automated email from the ASF dual-hosted git repository. cdeppisch 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 6c03aa4aafc Fix typo in classname and avoid unused variable in DataFormatTransformer 6c03aa4aafc is described below commit 6c03aa4aafcb7e4d500a9578e52b4ce5833ac8fb Author: Christoph Deppisch <cdeppi...@redhat.com> AuthorDate: Tue May 30 10:39:28 2023 +0200 Fix typo in classname and avoid unused variable in DataFormatTransformer --- .../org/apache/camel/processor/transformer/DataFormatTransformer.java | 2 +- .../{CustomTransformeReifier.java => CustomTransformerReifier.java} | 4 ++-- .../java/org/apache/camel/reifier/transformer/TransformerReifier.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/transformer/DataFormatTransformer.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/transformer/DataFormatTransformer.java index a2025a00498..64afbf8f78a 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/transformer/DataFormatTransformer.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/transformer/DataFormatTransformer.java @@ -83,7 +83,7 @@ public class DataFormatTransformer extends Transformer { } OutputStreamBuilder osb = OutputStreamBuilder.withExchange(exchange); LOG.debug("Marshaling with: {}", dataFormat); - dataFormat.marshal(exchange, message.getBody(), osb); + dataFormat.marshal(exchange, input, osb); message.setBody(osb.build()); } else { diff --git a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/CustomTransformeReifier.java b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/CustomTransformerReifier.java similarity index 93% rename from core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/CustomTransformeReifier.java rename to core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/CustomTransformerReifier.java index 493d8460ba2..26ed5f1839d 100644 --- a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/CustomTransformeReifier.java +++ b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/CustomTransformerReifier.java @@ -21,9 +21,9 @@ import org.apache.camel.model.transformer.CustomTransformerDefinition; import org.apache.camel.model.transformer.TransformerDefinition; import org.apache.camel.spi.Transformer; -public class CustomTransformeReifier extends TransformerReifier<CustomTransformerDefinition> { +public class CustomTransformerReifier extends TransformerReifier<CustomTransformerDefinition> { - public CustomTransformeReifier(CamelContext camelContext, TransformerDefinition definition) { + public CustomTransformerReifier(CamelContext camelContext, TransformerDefinition definition) { super(camelContext, (CustomTransformerDefinition) definition); } diff --git a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/TransformerReifier.java b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/TransformerReifier.java index a0e3d1d03a9..3e8e5f009a6 100644 --- a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/TransformerReifier.java +++ b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/transformer/TransformerReifier.java @@ -75,7 +75,7 @@ public abstract class TransformerReifier<T> extends AbstractReifier { private static TransformerReifier<? extends TransformerDefinition> coreReifier( CamelContext camelContext, TransformerDefinition definition) { if (definition instanceof CustomTransformerDefinition) { - return new CustomTransformeReifier(camelContext, definition); + return new CustomTransformerReifier(camelContext, definition); } else if (definition instanceof DataFormatTransformerDefinition) { return new DataFormatTransformerReifier(camelContext, definition); } else if (definition instanceof EndpointTransformerDefinition) {