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 2023/02/07 07:32:54 UTC
[camel-quarkus] 08/18: Fix #4454 to set jms properties with ActiveMQ connections in native building (#4455)
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch 2.13.x
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 35ba1915454344a43b7debc1fd80252adc7e445b
Author: Zheng Feng <zh...@gmail.com>
AuthorDate: Mon Jan 30 10:43:21 2023 +0800
Fix #4454 to set jms properties with ActiveMQ connections in native building (#4455)
---
.../quarkus/component/activemq/deployment/ActiveMQProcessor.java | 4 ++++
.../camel/quarkus/component/activemq/it/ActiveMQTestResource.java | 4 +++-
2 files changed, 7 insertions(+), 1 deletion(-)
diff --git a/extensions/activemq/deployment/src/main/java/org/apache/camel/quarkus/component/activemq/deployment/ActiveMQProcessor.java b/extensions/activemq/deployment/src/main/java/org/apache/camel/quarkus/component/activemq/deployment/ActiveMQProcessor.java
index 83335feb82..0885a13ba9 100644
--- a/extensions/activemq/deployment/src/main/java/org/apache/camel/quarkus/component/activemq/deployment/ActiveMQProcessor.java
+++ b/extensions/activemq/deployment/src/main/java/org/apache/camel/quarkus/component/activemq/deployment/ActiveMQProcessor.java
@@ -59,6 +59,10 @@ class ActiveMQProcessor {
return new ReflectiveClassBuildItem(true, false,
"java.net.Socket",
"sun.security.ssl.SSLSocketImpl",
+ "org.apache.activemq.ActiveMQConnectionFactory",
+ "org.apache.activemq.ActiveMQPrefetchPolicy",
+ "org.apache.activemq.RedeliveryPolicy",
+ "org.apache.activemq.blob.BlobTransferPolicy",
"org.apache.activemq.command.ConsumerInfo",
"org.apache.activemq.pool.PooledConnectionFactory",
"org.apache.commons.pool2.impl.DefaultEvictionPolicy",
diff --git a/integration-tests/activemq/src/test/java/org/apache/camel/quarkus/component/activemq/it/ActiveMQTestResource.java b/integration-tests/activemq/src/test/java/org/apache/camel/quarkus/component/activemq/it/ActiveMQTestResource.java
index 17dd6eb0b0..1191898bfa 100644
--- a/integration-tests/activemq/src/test/java/org/apache/camel/quarkus/component/activemq/it/ActiveMQTestResource.java
+++ b/integration-tests/activemq/src/test/java/org/apache/camel/quarkus/component/activemq/it/ActiveMQTestResource.java
@@ -51,7 +51,9 @@ public class ActiveMQTestResource implements QuarkusTestResourceLifecycleManager
return Collections.singletonMap(
"camel.component.activemq.broker-url",
String.format(
- "tcp://%s:%d?connectionTimeout=5000&tcpNoDelay=false&socket.OOBInline=false",
+ "tcp://%s:%d?connectionTimeout=5000&tcpNoDelay=false&socket.OOBInline=false" +
+ "&jms.checkForDuplicates=false&jms.redeliveryPolicy.redeliveryDelay=1000" +
+ "&jms.prefetchPolicy.queuePrefetch=1000&jms.blobTransferPolicy.bufferSize=102400",
container.getHost(),
container.getMappedPort(TCP_PORT)));
} catch (Exception e) {