lib/amq/client/async/adapters/event_machine.rb in amq-client-1.0.0.pre1 vs lib/amq/client/async/adapters/event_machine.rb in amq-client-1.0.0.pre2

@@ -171,12 +171,10 @@
           @auto_recovery     = (!!@settings[:auto_recovery])
 
           self.reset
           self.set_pending_connect_timeout((@settings[:timeout] || 3).to_f) unless defined?(JRUBY_VERSION)
 
-          if self.heartbeat_interval > 0
-            self.initialize_heartbeat_sender
-          end
+          self.initialize_heartbeat_sender if self.heartbeats_enabled?
         end # initialize(*args)
 
 
 
         # For EventMachine adapter, this is a no-op.