@Test void getShouldThrowWhenNotHealthyCassandra() { cassandraExtension.pause(); try { assertThatThrownBy(() -> new ResilientClusterProvider(cassandraExtension.clusterConfiguration() .maxRetry(1) .minDelay(1) .build(), CassandraConsistenciesConfiguration.DEFAULT) .get()) .isInstanceOf(Exception.class); } finally { cassandraExtension.unpause(); } }
@Override public Cluster get() { return cluster; }
ResilientClusterProvider implements Provider<Cluster> { @Override public Cluster get() { return cluster; } }
ResilientClusterProvider implements Provider<Cluster> { @Override public Cluster get() { return cluster; } @VisibleForTesting @Inject  ResilientClusterProvider(ClusterConfiguration configuration, CassandraConsistenciesConfiguration consistenciesConfiguration); }
ResilientClusterProvider implements Provider<Cluster> { @Override public Cluster get() { return cluster; } @VisibleForTesting @Inject  ResilientClusterProvider(ClusterConfiguration configuration, CassandraConsistenciesConfiguration consistenciesConfiguration); @Override Cluster get(); @PreDestroy void stop(); }
ResilientClusterProvider implements Provider<Cluster> { @Override public Cluster get() { return cluster; } @VisibleForTesting @Inject  ResilientClusterProvider(ClusterConfiguration configuration, CassandraConsistenciesConfiguration consistenciesConfiguration); @Override Cluster get(); @PreDestroy void stop();  }