diff --git a/narayana-spring-boot-core/pom.xml b/narayana-spring-boot-core/pom.xml index 316f52f2..77b785cf 100644 --- a/narayana-spring-boot-core/pom.xml +++ b/narayana-spring-boot-core/pom.xml @@ -48,6 +48,7 @@ org.messaginghub pooled-jms + true org.springframework.boot diff --git a/narayana-spring-boot-starter-it/pom.xml b/narayana-spring-boot-starter-it/pom.xml index d73ae7a3..532337be 100644 --- a/narayana-spring-boot-starter-it/pom.xml +++ b/narayana-spring-boot-starter-it/pom.xml @@ -54,6 +54,11 @@ agroal-spring-boot-starter test + + org.messaginghub + pooled-jms + test + org.apache.activemq artemis-jakarta-server diff --git a/narayana-spring-boot-starter/pom.xml b/narayana-spring-boot-starter/pom.xml index 96cb6059..dfe7ac07 100644 --- a/narayana-spring-boot-starter/pom.xml +++ b/narayana-spring-boot-starter/pom.xml @@ -47,6 +47,11 @@ jakarta.jms-api true + + org.messaginghub + pooled-jms + true + org.mockito mockito-junit-jupiter diff --git a/narayana-spring-boot-starter/src/main/java/dev/snowdrop/boot/narayana/autoconfigure/NarayanaAutoConfiguration.java b/narayana-spring-boot-starter/src/main/java/dev/snowdrop/boot/narayana/autoconfigure/NarayanaAutoConfiguration.java index 3405867c..5298727b 100644 --- a/narayana-spring-boot-starter/src/main/java/dev/snowdrop/boot/narayana/autoconfigure/NarayanaAutoConfiguration.java +++ b/narayana-spring-boot-starter/src/main/java/dev/snowdrop/boot/narayana/autoconfigure/NarayanaAutoConfiguration.java @@ -33,7 +33,9 @@ import dev.snowdrop.boot.narayana.core.jms.PooledXAConnectionFactoryWrapper; import dev.snowdrop.boot.narayana.core.properties.NarayanaProperties; import dev.snowdrop.boot.narayana.core.properties.NarayanaPropertiesInitializer; +import org.apache.commons.pool2.PooledObject; import org.jboss.tm.XAResourceRecoveryRegistry; +import org.messaginghub.pooled.jms.JmsPoolConnectionFactory; import org.springframework.beans.factory.ObjectProvider; import org.springframework.boot.autoconfigure.AutoConfiguration; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; @@ -185,7 +187,7 @@ public XAConnectionFactoryWrapper xaConnectionFactoryWrapper(TransactionManager } @ConditionalOnProperty(name = "narayana.messaginghub.enabled", havingValue = "true") - @ConditionalOnClass(Message.class) + @ConditionalOnClass({Message.class, JmsPoolConnectionFactory.class, PooledObject.class }) static class PooledJmsConfiguration { @Bean