# File gofer/messaging/consumer.rb, line 89 def stop() begin @incoming.stop() @thread.stop() @thread.join(90) end end