diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/RedeployTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/RedeployTest.java index c1068971fb..7c49053ba2 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/RedeployTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/RedeployTest.java @@ -20,6 +20,7 @@ package org.apache.activemq.artemis.tests.integration.jms; import javax.jms.Connection; import javax.jms.JMSException; import javax.jms.MessageConsumer; +import javax.jms.MessageProducer; import javax.jms.Queue; import javax.jms.Session; import java.net.URL; @@ -75,6 +76,18 @@ public class RedeployTest extends ActiveMQTestBase { Assert.assertEquals("jms.queue.NewQueue", embeddedJMS.getActiveMQServer().getAddressSettingsRepository().getMatch("jms").getDeadLetterAddress().toString()); Assert.assertEquals("jms.queue.NewQueue", embeddedJMS.getActiveMQServer().getAddressSettingsRepository().getMatch("jms").getExpiryAddress().toString()); + + ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(); + try (Connection connection = factory.createConnection()) { + Session session = connection.createSession(); + Queue queue = session.createQueue("DivertQueue"); + MessageProducer producer = session.createProducer(queue); + producer.send(session.createTextMessage("text")); + connection.start(); + MessageConsumer consumer = session.createConsumer(session.createQueue("NewQueue")); + Assert.assertNotNull("Divert wasn't redeployed accordingly", consumer.receive(5000)); + } + } finally { embeddedJMS.stop(); diff --git a/tests/integration-tests/src/test/resources/reload-test-updated-jms.xml b/tests/integration-tests/src/test/resources/reload-test-updated-jms.xml index 3e6e329146..a9d101614e 100644 --- a/tests/integration-tests/src/test/resources/reload-test-updated-jms.xml +++ b/tests/integration-tests/src/test/resources/reload-test-updated-jms.xml @@ -26,6 +26,7 @@ under the License. + @@ -83,6 +84,13 @@ under the License. + + +
jms.queue.DivertQueue
+ jms.queue.NewQueue +
+
+