Add cleanup logic to CCR retention lease test

This commit adds some logic to remove the mock transport rules at the
end of a CCR retention lease test.
This commit is contained in:
Jason Tedor 2019-02-20 13:18:51 -05:00
parent 224600f370
commit 90b1b36f50
No known key found for this signature in database
GPG Key ID: FA89F05560F16BC5

@ -459,7 +459,11 @@ public class CcrRetentionLeaseIT extends CcrIntegTestCase {
assertThat(shardStats.getRetentionLeaseStats().retentionLeases().leases(), empty());
}
} finally {
for (final ObjectCursor<DiscoveryNode> senderNode : followerClusterState.getState().nodes().getDataNodes().values()) {
final MockTransportService senderTransportService =
(MockTransportService) getFollowerCluster().getInstance(TransportService.class, senderNode.value.getName());
senderTransportService.clearAllRules();
}
}
}