class ElasticsearchClient {

	void sendBulk(HttpClient.OutputStreamHandler outputStreamHandler) {
		sendBulk(outputStreamHandler, true);
	}

	public  ElasticsearchClient(final CorePlugin corePlugin, final HttpClient httpClient, int esAvailabilityCheckIntervalSec, List<ElasticsearchAvailabilityObserver> elasticsearchAvailabilityObservers);

}