Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix mirror test that validates autostart

This commit is contained in:
Gary Tully 2023-02-08 16:44:42 +00:00
parent 1caa406bbf
commit 94516b8b37
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImplTest.java
View File

@ -731,7 +731,7 @@ public class ConfigurationImplTest extends ActiveMQTestBase {
insertionOrderedProperties.put("AMQPConnections.target.reconnectAttempts", -2); insertionOrderedProperties.put("AMQPConnections.target.reconnectAttempts", -2);
insertionOrderedProperties.put("AMQPConnections.target.user", "admin"); insertionOrderedProperties.put("AMQPConnections.target.user", "admin");
insertionOrderedProperties.put("AMQPConnections.target.password", "password"); insertionOrderedProperties.put("AMQPConnections.target.password", "password");
insertionOrderedProperties.put("AMQPConnections.target.autoStart", "true"); insertionOrderedProperties.put("AMQPConnections.target.autostart", "false");
insertionOrderedProperties.put("AMQPConnections.target.connectionElements.mirror.type", "MIRROR"); insertionOrderedProperties.put("AMQPConnections.target.connectionElements.mirror.type", "MIRROR");
insertionOrderedProperties.put("AMQPConnections.target.connectionElements.mirror.messageAcknowledgements", "true"); insertionOrderedProperties.put("AMQPConnections.target.connectionElements.mirror.messageAcknowledgements", "true");
insertionOrderedProperties.put("AMQPConnections.target.connectionElements.mirror.queueCreation", "true"); insertionOrderedProperties.put("AMQPConnections.target.connectionElements.mirror.queueCreation", "true");
@ -751,6 +751,7 @@ public class ConfigurationImplTest extends ActiveMQTestBase {
Assert.assertEquals(-2, connectConfiguration.getReconnectAttempts()); Assert.assertEquals(-2, connectConfiguration.getReconnectAttempts());
Assert.assertEquals("admin", connectConfiguration.getUser()); Assert.assertEquals("admin", connectConfiguration.getUser());
Assert.assertEquals("password", connectConfiguration.getPassword()); Assert.assertEquals("password", connectConfiguration.getPassword());
Assert.assertEquals(false, connectConfiguration.isAutostart());
Assert.assertEquals(1,connectConfiguration.getConnectionElements().size()); Assert.assertEquals(1,connectConfiguration.getConnectionElements().size());
AMQPBrokerConnectionElement amqpBrokerConnectionElement = connectConfiguration.getConnectionElements().get(0); AMQPBrokerConnectionElement amqpBrokerConnectionElement = connectConfiguration.getConnectionElements().get(0);
Assert.assertTrue(amqpBrokerConnectionElement instanceof AMQPMirrorBrokerConnectionElement); Assert.assertTrue(amqpBrokerConnectionElement instanceof AMQPMirrorBrokerConnectionElement);