You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2026/05/07 06:53:52 UTC
(camel-quarkus) 11/12: Set objectMessageEnabled=true for messaging tests that need it
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 05eaf416d9a07e8fab2fcf80e854d05c6ee38e9e
Author: James Netherton <ja...@gmail.com>
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")