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

NO-JIRA Improve test

This commit is contained in:
Clebert Suconic 2019-02-19 19:31:49 -05:00
parent a68381904f
commit 43c0868d72
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/ClusteredBridgeReconnectTest.java
View File

@ -86,7 +86,7 @@ public class ClusteredBridgeReconnectTest extends ClusterTestBase {
MessageFlowRecord record = connection.getRecords().values().toArray(new MessageFlowRecord[1])[0]; MessageFlowRecord record = connection.getRecords().values().toArray(new MessageFlowRecord[1])[0];
ClusterConnectionBridge bridge = (ClusterConnectionBridge) record.getBridge(); ClusterConnectionBridge bridge = (ClusterConnectionBridge) record.getBridge();
Wait.assertEquals(2, bridge.getSessionFactory().getServerLocator().getTopology().getMembers()::size); Wait.assertEquals(2, () -> bridge.getSessionFactory().getServerLocator().getTopology().getMembers().size());
ArrayList<TopologyMemberImpl> originalmembers = new ArrayList<>(bridge.getSessionFactory().getServerLocator().getTopology().getMembers()); ArrayList<TopologyMemberImpl> originalmembers = new ArrayList<>(bridge.getSessionFactory().getServerLocator().getTopology().getMembers());
for (int i = 0; i < NUMBER_OF_MESSAGES; i++) { for (int i = 0; i < NUMBER_OF_MESSAGES; i++) {
@ -99,7 +99,7 @@ public class ClusteredBridgeReconnectTest extends ClusterTestBase {
} }
} }
Wait.assertEquals(2, bridge.getSessionFactory().getServerLocator().getTopology().getMembers()::size); Wait.assertEquals(2, () -> bridge.getSessionFactory().getServerLocator().getTopology().getMembers().size());
ArrayList<TopologyMemberImpl> afterReconnectedMembers = new ArrayList<>(bridge.getSessionFactory().getServerLocator().getTopology().getMembers()); ArrayList<TopologyMemberImpl> afterReconnectedMembers = new ArrayList<>(bridge.getSessionFactory().getServerLocator().getTopology().getMembers());