This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit d09751438e9889207b3111a3879e3d4290bc610b Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Fri Mar 1 11:21:35 2024 +0100 CAMEL-20477: TwoConsumerOnSameQueueTest needs an exclusive broker and context --- .../component/jms/TwoConsumerOnSameQueueTest.java | 28 +++++++++++++++++++++- 1 file changed, 27 insertions(+), 1 deletion(-) diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java index a142011ae43..2fa7d237ca4 100644 --- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java +++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java @@ -18,9 +18,16 @@ package org.apache.camel.component.jms; import java.util.concurrent.TimeUnit; +import jakarta.jms.ConnectionFactory; + +import org.apache.camel.CamelContext; import org.apache.camel.Exchange; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; +import org.apache.camel.test.infra.artemis.common.ConnectionFactoryHelper; +import org.apache.camel.test.infra.artemis.services.ArtemisService; +import org.apache.camel.test.infra.artemis.services.ArtemisServiceFactory; +import org.apache.camel.test.junit5.CamelTestSupport; import org.awaitility.Awaitility; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Tag; @@ -28,14 +35,33 @@ import org.junit.jupiter.api.Tags; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.condition.DisabledIfSystemProperty; +import org.junit.jupiter.api.extension.RegisterExtension; +import static org.apache.camel.component.jms.JmsComponent.jmsComponentAutoAcknowledge; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.junit.jupiter.api.Assertions.assertTrue; @Tags({ @Tag("not-parallel") }) @TestInstance(TestInstance.Lifecycle.PER_METHOD) -public class TwoConsumerOnSameQueueTest extends AbstractPersistentJMSTest { +public class TwoConsumerOnSameQueueTest extends CamelTestSupport { + + @RegisterExtension + public static ArtemisService service = ArtemisServiceFactory.createPersistentVMService(); + + @Override + protected CamelContext createCamelContext() throws Exception { + CamelContext camelContext = super.createCamelContext(); + + createConnectionFactory(camelContext); + + return camelContext; + } + + protected void createConnectionFactory(CamelContext camelContext) { + ConnectionFactory connectionFactory = ConnectionFactoryHelper.createConnectionFactory(service); + camelContext.addComponent("activemq", jmsComponentAutoAcknowledge(connectionFactory)); + } @Test public void testTwoConsumerOnSameQueue() throws Exception {