Blidly retrying may be usafe.

fleet.gemspec

@@ -1,6 +1,6 @@
 Gem::Specification.new do |s|
   s.name = "fleet"
-  s.version = "0.1.6"
+  s.version = "0.1.7"
 
   s.required_rubygems_version = Gem::Requirement.new(">= 0") if s.respond_to? :required_rubygems_version=
   s.authors = ["Mark McGranaghan"]

lib/fleet.rb

@@ -18,7 +18,7 @@ def initialize(options = {})
 
   def query(q)
     request = @json_encoder.encode(q)
-    response = write_and_read_with_retry(request)
+    response = write_and_read(request)
     status, value = @json_parser.parse(response)
     case status
     when 0
@@ -57,16 +57,6 @@ def disconnect
     @socket = nil
   end
 
-  def write_and_read_with_retry(request)
-    begin
-      write_and_read(request)
-    rescue Errno::ECONNRESET, Errno::EPIPE, Errno::ECONNABORTED, Timeout::Error
-      disconnect
-      connect
-      write_and_read(request)
-    end
-  end
-
   def write_and_read(request)
     with_timeout do
       @socket.write(request)