This is an automated email from the ASF dual-hosted git repository. JiriOndrusek pushed a commit to branch camel-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 8a707abe2f49570575892ccf94c1fa690b324fc1 Author: James Netherton <[email protected]> AuthorDate: Tue May 5 15:39:49 2026 +0100 Set objectMessageEnabled=true for messaging tests that need it --- .../quarkus/component/messaging/it/MessagingCommonResource.java | 2 +- .../camel/quarkus/component/messaging/it/MessagingCommonRoutes.java | 2 +- .../messaging/common/src/main/resources/application.properties | 4 ---- .../java/org/apache/camel/quarkus/messaging/jms/JmsResource.java | 5 +++-- .../main/java/org/apache/camel/quarkus/messaging/jms/JmsRoutes.java | 4 ++-- 5 files changed, 7 insertions(+), 10 deletions(-) diff --git a/integration-tests-support/messaging/common/src/main/java/org/apache/camel/quarkus/component/messaging/it/MessagingCommonResource.java b/integration-tests-support/messaging/common/src/main/java/org/apache/camel/quarkus/component/messaging/it/MessagingCommonResource.java index c5b98babd5..2959fa2ca7 100644 --- a/integration-tests-support/messaging/common/src/main/java/org/apache/camel/quarkus/component/messaging/it/MessagingCommonResource.java +++ b/integration-tests-support/messaging/common/src/main/java/org/apache/camel/quarkus/component/messaging/it/MessagingCommonResource.java @@ -217,7 +217,7 @@ public class MessagingCommonResource { MockEndpoint mockEndpoint = context.getEndpoint("mock:objectTestResult", MockEndpoint.class); mockEndpoint.expectedMessageCount(1); - producerTemplate.sendBody(componentScheme + ":queue:" + queueName, new Person(name)); + producerTemplate.sendBody(componentScheme + ":queue:" + queueName + "?objectMessageEnabled=true", new Person(name)); mockEndpoint.assertIsSatisfied(); diff --git a/integration-tests-support/messaging/common/src/main/java/org/apache/camel/quarkus/component/messaging/it/MessagingCommonRoutes.java b/integration-tests-support/messaging/common/src/main/java/org/apache/camel/quarkus/component/messaging/it/MessagingCommonRoutes.java index 084aa8b12d..524f5aa6a8 100644 --- a/integration-tests-support/messaging/common/src/main/java/org/apache/camel/quarkus/component/messaging/it/MessagingCommonRoutes.java +++ b/integration-tests-support/messaging/common/src/main/java/org/apache/camel/quarkus/component/messaging/it/MessagingCommonRoutes.java @@ -78,7 +78,7 @@ public class MessagingCommonRoutes extends RouteBuilder { }) .to("mock:txResult"); - fromF("%s:queue:testJmsObject", componentScheme) + fromF("%s:queue:testJmsObject?objectMessageEnabled=true", componentScheme) .to("mock:objectTestResult"); // Topic routes diff --git a/integration-tests-support/messaging/common/src/main/resources/application.properties b/integration-tests-support/messaging/common/src/main/resources/application.properties index 9b62feb2f6..f848f3ecb4 100644 --- a/integration-tests-support/messaging/common/src/main/resources/application.properties +++ b/integration-tests-support/messaging/common/src/main/resources/application.properties @@ -15,7 +15,3 @@ ## limitations under the License. ## --------------------------------------------------------------------------- quarkus.transaction-manager.object-store.directory=target/narayana - -# For testing JMS object serialization -camel.component.jms.object-message-enabled=true - diff --git a/integration-tests-support/messaging/jms/src/main/java/org/apache/camel/quarkus/messaging/jms/JmsResource.java b/integration-tests-support/messaging/jms/src/main/java/org/apache/camel/quarkus/messaging/jms/JmsResource.java index 3249cf8ba0..6149be0e7a 100644 --- a/integration-tests-support/messaging/jms/src/main/java/org/apache/camel/quarkus/messaging/jms/JmsResource.java +++ b/integration-tests-support/messaging/jms/src/main/java/org/apache/camel/quarkus/messaging/jms/JmsResource.java @@ -108,7 +108,7 @@ public class JmsResource { mockEndpoint.expectedMessageCount(1); producerTemplate.sendBody( - componentScheme + ":queue:" + queueName + "?transferExchange=true", message); + componentScheme + ":queue:" + queueName + "?transferExchange=true&objectMessageEnabled=true", message); mockEndpoint.assertIsSatisfied(); @@ -125,7 +125,8 @@ public class JmsResource { public Response testTransferException(@PathParam("queueName") String queueName) { try { producerTemplate.requestBody( - componentScheme + ":queue:" + queueName + "?transferException=true&replyTo=exception.queue", + componentScheme + ":queue:" + queueName + + "?transferException=true&replyTo=exception.queue&objectMessageEnabled=true", "bad payload"); } catch (RuntimeCamelException e) { Class<? extends Throwable> exception = e.getCause().getClass(); diff --git a/integration-tests-support/messaging/jms/src/main/java/org/apache/camel/quarkus/messaging/jms/JmsRoutes.java b/integration-tests-support/messaging/jms/src/main/java/org/apache/camel/quarkus/messaging/jms/JmsRoutes.java index 221f664005..90a9f9121e 100644 --- a/integration-tests-support/messaging/jms/src/main/java/org/apache/camel/quarkus/messaging/jms/JmsRoutes.java +++ b/integration-tests-support/messaging/jms/src/main/java/org/apache/camel/quarkus/messaging/jms/JmsRoutes.java @@ -37,10 +37,10 @@ public class JmsRoutes extends RouteBuilder { @Override public void configure() throws Exception { - fromF("%s:queue:testJmsTransferExchange?transferExchange=true", componentScheme) + fromF("%s:queue:testJmsTransferExchange?transferExchange=true&objectMessageEnabled=true", componentScheme) .to("mock:transferExchangeResult"); - fromF("%s:queue:testJmsTransferException?transferException=true", componentScheme) + fromF("%s:queue:testJmsTransferException?transferException=true&objectMessageEnabled=true", componentScheme) .throwException(new IllegalStateException("Forced exception")); from("direct:computedDestination")
