event_machine.rb in amq-client-0.9.10

- old
+ new

@@ -170,12 +170,10 @@
 
           @auto_recovery     = (!!@settings[:auto_recovery])
 
           self.reset
           self.set_pending_connect_timeout((@settings[:timeout] || 3).to_f) unless defined?(JRUBY_VERSION)
-
-          self.initialize_heartbeat_sender if self.heartbeats_enabled?
         end # initialize(*args)
 
 
 
         # For EventMachine adapter, this is a no-op.
@@ -264,11 +262,9 @@
           # now we can set it. MK.
           @had_successfully_connected_before = true
           @reconnecting                      = false
           @handling_skipped_hearbeats        = false
           @last_server_heartbeat             = Time.now
-
-          self.initialize_heartbeat_sender if heartbeats_enabled?
 
           self.handshake
         end
 
         # @private