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 <[email protected]> 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) {
