Class SniffOnFailureListener

java.lang.Object
org.elasticsearch.client.RestClient.FailureListener
org.elasticsearch.client.sniff.SniffOnFailureListener

public class SniffOnFailureListener extends org.elasticsearch.client.RestClient.FailureListener
RestClient.FailureListener implementation that allows to perform sniffing on failure. Gets notified whenever a failure happens and uses a Sniffer instance to manually reload hosts and sets them back to the RestClient. The Sniffer instance needs to be lazily set through setSniffer(Sniffer).
  • Constructor Details

    • SniffOnFailureListener

      public SniffOnFailureListener()
  • Method Details

    • setSniffer

      public void setSniffer(Sniffer sniffer)
      Sets the Sniffer instance used to perform sniffing
      Throws:
      IllegalStateException - if the sniffer was already set, as it can only be set once
    • onFailure

      public void onFailure(org.elasticsearch.client.Node node)
      Overrides:
      onFailure in class org.elasticsearch.client.RestClient.FailureListener