event_machine.rb in amq-client-0.9.8

- old
+ new

@@ -3,12 +3,10 @@
 require "eventmachine"
 require "amq/client"
 require "amq/client/async/adapter"
 require "amq/client/framing/string/frame"
 
-require "socket"
-
 module AMQ
   module Client
     module Async
       class EventMachineClient < EM::Connection
 
@@ -139,19 +137,9 @@
 
 
 
         def initialize(*args)
           super(*args)
-
-          begin
-            # EventMachine 1.0+
-            if self.respond_to?(:set_sock_opt)
-              set_sock_opt(Socket::SOL_SOCKET, Socket::SO_KEEPALIVE, true)
-            end
-          rescue Errno::EINVAL => e
-            # ignored, when connections fail this exception is raised with very
-            # obscure error messages. Bravo Ruby, bravo EventMachine.
-          end
 
           self.logger   = self.class.logger
 
           # channel => collected frames. MK.
           @frames            = Hash.new { Array.new }