http_poller.rb in logstash-input-http_poller-1.1.1

- old
+ new

@@ -16,10 +16,11 @@
 #       test1 => "http://localhost:9200"
 #       test2 => {
 #         # Supports all options supported by ruby's Manticore HTTP client
 #         method => get
 #         url => "http://localhost:9200/_cluster/health"
+#         automatic_retries => 2 # Retry the URL twice
 #         headers => {
 #           Accept => "application/json"
 #         }
 #         auth => {
 #           user => "AzureDiamond"
@@ -42,10 +43,15 @@
 # }
 
 class LogStash::Inputs::HTTP_Poller < LogStash::Inputs::Base
   include LogStash::PluginMixins::HttpClient
 
+  # Default client options for requests
+  DEFAULT_SPEC = {
+    :automatic_retries => 0 # By default manticore retries 3 times, make this explicit
+  }
+
   config_name "http_poller"
 
   default :codec, "json"
 
   # A Hash of urls in this format : "name" => "url"
@@ -80,13 +86,13 @@
   end
 
   private
   def normalize_request(url_or_spec)
     if url_or_spec.is_a?(String)
-      res = [:get, url_or_spec]
+      res = [:get, url_or_spec, DEFAULT_SPEC.clone]
     elsif url_or_spec.is_a?(Hash)
       # The client will expect keys / values
-      spec = Hash[url_or_spec.clone.map {|k,v| [k.to_sym, v] }] # symbolize keys
+      spec = Hash[DEFAULT_SPEC.merge(url_or_spec).map {|k,v| [k.to_sym, v] }] # symbolize keys
 
       # method and url aren't really part of the options, so we pull them out
       method = (spec.delete(:method) || :get).to_sym.downcase
       url = spec.delete(:url)
 