import java.util.Properties;
import static org.fest.assertions.Assertions.assertThat;
+import static org.fest.assertions.Fail.fail;
public class SearchServerTest {
searchServer.awaitStop();
searchServer = null;
try {
- assertThat(client.admin().cluster().prepareClusterStats().get().getStatus()).isNotEqualTo(ClusterHealthStatus.GREEN);
+ client.admin().cluster().prepareClusterStats().get();
+ fail();
} catch (NoNodeAvailableException exception) {
- assertThat(exception.getMessage()).isEqualTo("No node available");
+ // ok
}
}
import org.elasticsearch.search.aggregations.metrics.max.Max;
import org.picocontainer.Startable;
import org.sonar.core.profiling.Profiling;
-import org.sonar.server.search.ClusterHealth;
-import org.sonar.server.search.SearchClient;
import org.sonar.server.es.request.ProxyBulkRequestBuilder;
import org.sonar.server.es.request.ProxyClusterHealthRequestBuilder;
import org.sonar.server.es.request.ProxyClusterStateRequestBuilder;
import org.sonar.server.es.request.ProxyRefreshRequestBuilder;
import org.sonar.server.es.request.ProxySearchRequestBuilder;
import org.sonar.server.es.request.ProxySearchScrollRequestBuilder;
+import org.sonar.server.search.ClusterHealth;
+import org.sonar.server.search.SearchClient;
/**
* Facade to connect to Elasticsearch node. Handles correctly errors (logging + exceptions