This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch move-4.5.0-SNAP in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 8d8ad84f3770a60b3a1f3e6257de8739d12e51ec Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Mar 19 10:32:11 2024 +0100 Align to 4.5.0-SNAPSHOT preparing to release Signed-off-by: Andrea Cosentino <[email protected]> --- .../kamelets/catalog/KameletsCatalogTest.java | 2 +- library/camel-kamelets-utils/pom.xml | 2 +- .../kafka/KafkaHeaderDeserializerTest.java | 36 +--------------------- 3 files changed, 3 insertions(+), 37 deletions(-) diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 381a7857..04765857 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -143,7 +143,7 @@ public class KameletsCatalogTest { verifyHeaders("aws-not-exists", 0); verifyHeaders("azure-eventhubs-sink", 2); verifyHeaders("azure-functions-sink", 8); - verifyHeaders("azure-servicebus-source", 22); + verifyHeaders("azure-servicebus-source", 21); verifyHeaders("azure-storage-blob-source", 34); verifyHeaders("azure-storage-blob-sink", 33); verifyHeaders("azure-storage-blob-changefeed-source", 34); diff --git a/library/camel-kamelets-utils/pom.xml b/library/camel-kamelets-utils/pom.xml index fe6572bf..5fc818c4 100644 --- a/library/camel-kamelets-utils/pom.xml +++ b/library/camel-kamelets-utils/pom.xml @@ -85,6 +85,7 @@ <scope>provided</scope> </dependency> + <!-- Test scoped dependencies --> <dependency> <groupId>org.junit.jupiter</groupId> @@ -132,7 +133,6 @@ <version>${log4j2-version}</version> <scope>test</scope> </dependency> - </dependencies> </project> diff --git a/library/camel-kamelets-utils/src/test/java/org/apache/camel/kamelets/utils/serialization/kafka/KafkaHeaderDeserializerTest.java b/library/camel-kamelets-utils/src/test/java/org/apache/camel/kamelets/utils/serialization/kafka/KafkaHeaderDeserializerTest.java index 2d7e3bd8..37d34291 100644 --- a/library/camel-kamelets-utils/src/test/java/org/apache/camel/kamelets/utils/serialization/kafka/KafkaHeaderDeserializerTest.java +++ b/library/camel-kamelets-utils/src/test/java/org/apache/camel/kamelets/utils/serialization/kafka/KafkaHeaderDeserializerTest.java @@ -22,6 +22,7 @@ import java.util.Arrays; import org.apache.camel.Exchange; import org.apache.camel.impl.DefaultCamelContext; +import org.apache.camel.spi.TypeConverterRegistry; import org.apache.camel.support.DefaultExchange; import org.apache.camel.support.SimpleTypeConverter; import org.junit.jupiter.api.Assertions; @@ -59,41 +60,6 @@ class KafkaHeaderDeserializerTest { Assertions.assertEquals("1", exchange.getMessage().getHeader("number")); } - @Test - void shouldDeserializeHeadersViaTypeConverter() throws Exception { - camelContext.setTypeConverter(new SimpleTypeConverter(true, (type, exchange, value) -> "converted")); - - Exchange exchange = new DefaultExchange(camelContext); - - exchange.getMessage().setHeader("foo", "bar"); - exchange.getMessage().setHeader("fooBytes", "barBytes".getBytes(StandardCharsets.UTF_8)); - exchange.getMessage().setHeader("fooNull", null); - - processor.enabled = true; - processor.process(exchange); - - Assertions.assertTrue(exchange.getMessage().hasHeaders()); - Assertions.assertEquals("converted", exchange.getMessage().getHeader("foo")); - Assertions.assertEquals("converted", exchange.getMessage().getHeader("fooBytes")); - Assertions.assertEquals("converted", exchange.getMessage().getHeader("fooNull")); - } - - @Test - void shouldFallbackToDefaultConverter() throws Exception { - camelContext.setTypeConverter(null); - Exchange exchange = new DefaultExchange(camelContext); - - exchange.getMessage().setHeader("foo", "bar"); - exchange.getMessage().setHeader("fooBytes", "barBytes".getBytes(StandardCharsets.UTF_8)); - - processor.enabled = true; - processor.process(exchange); - - Assertions.assertTrue(exchange.getMessage().hasHeaders()); - Assertions.assertEquals("bar", exchange.getMessage().getHeader("foo")); - Assertions.assertEquals("barBytes", exchange.getMessage().getHeader("fooBytes")); - } - @Test void shouldNotDeserializeHeadersWhenDisabled() throws Exception { Exchange exchange = new DefaultExchange(camelContext);
