Add close statements to http calls to free up sockets

ennui2342 · May 21, 2012 · d2ce317 · d2ce317
1 parent 3a7b307
commit d2ce317
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/lib/qswarm/speakers/http.rb b/lib/qswarm/speakers/http.rb
@@ -37,23 +37,25 @@ def publish(format, msg)
             http = EventMachine::HttpRequest.new(URI.join(@uri.to_s, msg)).get :head => head
           end
           http.errback do
-            logger.error "Error sending #{msg} to #{@name}: #{http.error}/#{http.response}"
+            logger.error "Error sending #{msg} to #{@name}: #{http.error}/#{http.response_header.status} #{http.response}"
           end
-          http.callback do 
+          http.callback do
             if @args.expect != http.response_header.status
               logger.error "#{@uri.to_s} Unexpected response code: #{http.response_header.status} #{http.response}"
             end
+            http.close
           end
 
         when :post
           http = EventMachine::HttpRequest.new(@uri).post :head => head, :body => msg
           http.errback do
             logger.error "Error sending #{msg} to #{@name}: #{http.error}/#{http.response_header.status} #{http.response}"
           end
-          http.callback do 
+          http.callback do
             if @args.expect != http.response_header.status
               logger.error "#{@uri.to_s} Unexpected response code: #{http.response_header.status} #{http.response}"
             end
+            http.close
           end
         end
       end