Skip to content

Commit

Permalink
fix mirror test that validates autostart
Browse files Browse the repository at this point in the history
  • Loading branch information
gtully committed Feb 8, 2023
1 parent 1caa406 commit 94516b8
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -731,7 +731,7 @@ private void testAMQPConnectionsConfiguration(boolean sync) throws Throwable {
insertionOrderedProperties.put("AMQPConnections.target.reconnectAttempts", -2);
insertionOrderedProperties.put("AMQPConnections.target.user", "admin");
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.messageAcknowledgements", "true");
insertionOrderedProperties.put("AMQPConnections.target.connectionElements.mirror.queueCreation", "true");
Expand All @@ -751,6 +751,7 @@ private void testAMQPConnectionsConfiguration(boolean sync) throws Throwable {
Assert.assertEquals(-2, connectConfiguration.getReconnectAttempts());
Assert.assertEquals("admin", connectConfiguration.getUser());
Assert.assertEquals("password", connectConfiguration.getPassword());
Assert.assertEquals(false, connectConfiguration.isAutostart());
Assert.assertEquals(1,connectConfiguration.getConnectionElements().size());
AMQPBrokerConnectionElement amqpBrokerConnectionElement = connectConfiguration.getConnectionElements().get(0);
Assert.assertTrue(amqpBrokerConnectionElement instanceof AMQPMirrorBrokerConnectionElement);
Expand Down

0 comments on commit 94516b8

Please sign in to comment.