Method: MessageBus::Client#cancel

Defined in:
lib/message_bus/client.rb

#cancel ⇒ Object 



24
25
26
27
28
29
30
31
 
# File 'lib/message_bus/client.rb', line 24

def cancel
  if cleanup_timer
    # concurrency may nil cleanup timer
    cleanup_timer.cancel rescue nil
    self.cleanup_timer = nil
  end
  ensure_closed!
end