protected TransportClient client;
protected String clusterName;
protected String[] addresses;
protected List<OnConnectListener> onConnectListenerList = new ArrayList<>();
private volatile boolean connected;
<BUG>protected final Scroll scrollForDelete = new Scroll(TimeValue.timeValueMinutes(1));
protected final int sizeForDelete = 10;
public EsClient() {</BUG>
clusterName = System.getProperty(CLUSTER_NAME, "elasticsearch");
addresses = Arrays.stream(System.getProperty(TRANSPORT_ADDRESSES, "localhost:9300").split(",")).map(v -> v.trim())

protected TransportClient client;
protected String clusterName;
protected String[] addresses;
protected List<OnConnectListener> onConnectListenerList = new ArrayList<>();
private volatile boolean connected;
protected Scroll scrollForDelete = new Scroll(TimeValue.timeValueMinutes(1));
protected int sizeForDelete = 10;
protected long retryInterval = 60 * 1000;
protected int maxRetryCount = 10;
protected long connTimeout = 180 * 1000;
public EsClient() {
clusterName = System.getProperty(CLUSTER_NAME, "elasticsearch");
addresses = Arrays.stream(System.getProperty(TRANSPORT_ADDRESSES, "localhost:9300").split(",")).map(v -> v.trim())
