# File lib/ruote-amqp.rb, line 71 def stop! return unless started? AMQP.stop Thread.main[:ruote_amqp_connection].join Thread.main[:ruote_amqp_started] = false end