# File lib/mq.rb, line 797 def reset @deferred_status = nil @channel = nil initialize @connection @consumers = {} exs = @exchanges @exchanges = {} exs.each{ |_,e| e.reset } if exs qus = @queues @queues = {} qus.each{ |_,q| q.reset } if qus prefetch(@prefetch_size) if @prefetch_size end